一、阻塞
服务器端
public class BIOServer {
public static void main(String[] args) throws Exception {
ServerSocket sc = new ServerSocket(9093);
System.out.println("服务器启动成...
在并发写入的时候,leveldb巧妙地利用一个时间窗口做batch写入,这部分代码值得一读:
Status DBImpl::Write(const WriteOptions& options, WriteBatch* my_batch) {
// A begin
Writer w(&mutex_);
...