fbe*_*oit 4 java multithreading volatile memory-visibility
如果我有一个字节队列,它应该有一个线程生成器,另一个消费者:
class ByteQueue{
byte[] buf;
/*volatile?*/ int readIdx;
/*volatile?*/ int writeIdx;
Runnable writeListener;
Runnable readListener;
// ...
void write( byte[] b ){
int wr = writeIdx;
int rd = readIdx;
// check consistency and free space using wr+rd
// copy to buf, starting at wr, eventually wrap around
// update writeIdx afterwards
writeIdx = ( wr + b.length ) % buf.length;
// callback to notify consumer for data available
writeListener.run();
}
void read( byte[] b ){
int wr = writeIdx;
int rd = readIdx;
// check consistency and available data using wr+rd
// copy buf to b, starting at rd, eventually wrap around
// update readIdx afterwards
readIdx = ( rd + b.length ) % buf.length;
// callback to notify producer for free space available
readListener.run();
}
int available() { return (writeIdx - readIdx) % buf.length; }
int free() { return buf.length - available() -1; }
// ...
}
Run Code Online (Sandbox Code Playgroud)
这种类型的队列不需要同步.
readIdx仅由reader线程修改,
writeIdx仅由writer线程修改.
readIdx == writeIdx意味着,没有内容.
并且队列只能占用buf.length-1字节的数据.
是否需要挥发物或者是否可以省略它们,因为只有一个线程是一个整数状态的修饰符?
弗兰克
如果另一个线程必须读取它,它需要是易失性的.该volatile关键字向JVM指示无法缓存该值或重新排序其更新,否则其值的更新可能对其他线程不可见.
可见性问题也延伸到buf阵列.由于buf需要随索引一步改变,因此看起来需要同步write和read方法.同步使更改可见,并确保并发调用不会导致索引和buf内容变得不一致.
| 归档时间: |
|
| 查看次数: |
277 次 |
| 最近记录: |