java - 阻塞队列和 InterruptedException

Question

我有一个 A 类，其属性为 LinkedBlockingQueue。在 A 的一种方法中，我调用 LinkedBlockingQueue.put() 方法，因为我想在队列中插入一个项目。但是，如果队列已满，我的线程将等到空间可用或我的线程被中断。

问题是即使我的线程被中断，我也希望该项目在队列中。

有没有办法确保我的项目已插入队列？

谢谢

Answer 1

如果队列已满，您必须决定是否要等待。如果你设置它，你不能告诉它忽略最大长度。

如果队列太大，您可以做的是减慢生产者的速度。如果您愿意，这将允许您“忽略”最大值。例如中断。

Answer 2

我看到的唯一方法是在循环中调用 queue.put() 。这种方式也许

boolean added = false;

while ( !added){
    try{
        queue.put(value);
        added = true;
    }catch(InterruptedException ie){
        // do something if required

        // make sure to set the interrupted flag on the thread, since it was cleared
        // when the exception was thrown
        Thread.currentThread().interrupt();
    }
}

if(Thread.currentThread.isInterrupted()){
    // you were previously interrupted before, so try to exit gracefully
    return;
}