如果在
Java中使用以下“idiom”中断,例如
from this answer.
- while (!Thread.currentThread().isInterrupted()) {
- try {
- Object value = queue.take();
- handle(value);
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- }
- }
在take是阻塞操作的情况下,如果在Thread.currentThread().isInterrupted()的检查和调用queue.take()之间中断“到达”,则暂时不能忽略中断吗？这不是“检查而非行动”的行动吗？如果是这样,如果线程被中断,它是否可以保证在任何情况下都保留循环？
可以使用poll with a timeout以便在超时后保留循环,但是是否可以检查中断状态并以原子方式对其进行操作？
解决方法
我会交换try / catch和while循环：
- try {
- while (true) {
- Object value = queue.take();
- handle(value);
- }
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- }
如果线程被中断,take()操作将立即抛出InterruptedException,同时中断while循环.
