alexzfx/engine

第一届PolarDB数据库性能大赛代码。Java语言实现

engine's Issues

关于write的并发问题

write函数中的这部分代码似乎会产生并发问题

        // ...
        int hash = valueFileHash(numkey);
        int off = valueOffsets[hash].getAndIncrement();
        try {
            ByteBuffer keyBuffer = keyMappedByteBuffers[hash].slice();
            keyBuffer.position(keyOffsets[hash].getAndAdd(KEY_AND_OFF_LEN));
            keyBuffer.putLong(numkey).putInt(off);
       // ...

假设两个线程同时调用write方法并且产生的hash相同时，有如下执行顺序：

1. t1执行keyBuffer.position() -> buffer位置变成了x
2. t2执行keyBuffer.position() -> buffer位置变成了x + 16
3. t1执行keyBuffer.putLong() -> buffer中为 [key1]
4. t2执行keyBuffer.putLong() -> buffer中为 [key1, key2]
5. t1执行keyBuffer.putInt() -> buffer中为 [key1, key2, off1]
6. t2执行keyBuffer.putInt() -> buffer中为 [key1, key2, off1, off2]

此时似乎应该会产生不一致的问题。
没有任何恶意，希望能学习一下😊