如下阻塞隊列+線程的代碼，很常見，當服務停止時，如何停止被BlockingQueue阻塞的線程？
BlockingQueue blockingQueue = new ArrayBlockingQueue(10);
final Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
Integer el = blockingQueue.take();
System.out.println(el);
} catch (InterruptedException e) {
}
}
}
});
方法是當服務停止時，觸發一個操作，給blockingQueue放一個特殊的元素，如上面，傳一個值為-1的元素代表停止事件，線程取到這個特殊元素時就跳出循環：
final int STOP_CODE = -1;
BlockingQueue blockingQueue = new ArrayBlockingQueue(10);
final Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
Integer el = blockingQueue.take();
// quit loop when receive stop event
if (STOP_CODE == el) {
break;
}
//do something useful
System.out.println(el);
} catch (InterruptedException e) {
}
}
}
});
分享到:
