Блокировка очереди и InterruptedException

Question

У меня есть класс A со свойством LinkedBlockingQueue. В одном методе A я вызываю метод LinkedBlockingQueue.put(), так как я хочу вставить элемент в очередь. Но, если очередь заполнена, мой поток будет ждать, пока не будет доступно пространство, или пока мой поток не будет прерван.

Проблема в том, что даже если мой поток прерывается, я хочу, чтобы элемент находился в очереди.

Есть ли способ удостовериться, что мой элемент был вставлен в очередь?

Благодаря

Answer 1

Единственный способ, по которому я вижу, - вызвать 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; 
} 

Answer 2

Вы должны решить, хотите ли вы ждать, если очередь заполнена или нет. Вы не можете сказать ему игнорировать максимальную длину, если вы ее установите.

Что вы можете сделать, это медленный производитель, если очередь слишком велика. Это позволит вам «игнорировать» максимум, если хотите. например на прерывание.