ブロッキングキューの実装

Question

私は今、セマフォを持つカスタムブロッキングキューを実装しました。

キューが空の場合、私のキューはセマフォによってブロックされていません。

は、ここに私の実装です：

package poolThread; 

import java.util.LinkedList; 
import java.util.Queue; 
import java.util.concurrent.Semaphore; 

public class MyQueue<E> { 
Semaphore s = new Semaphore(0, true); 
private Queue<E> queue = new LinkedList<E>(); 


public boolean isEmpty(){ 
    return this.queue.isEmpty(); 
} 
public void enqueue(E e){ 
    queue.add(e); 
    s.release(); 
} 
public E dequeue(){ 
    E e = null; 
    try { 
     s.acquire(); 
    } catch (InterruptedException e1) { 
     // TODO Auto-generated catch block 
     e1.printStackTrace(); 
    } 
    e = queue.remove(); 
    return e; 

} 

}

あなたは私が私のコードに障害を見つけるのに役立つだろうか？

Answer 1

ここでの問題は、LinkedListです。これはスレッドセーフではありません。したがって、許可が適切に取得されたとしても、LinkedListのremove()操作は問題を引き起こす可能性があります。

MyQueue<String> x = new MyQueue<>(); 

ExecutorService es = Executors.newFixedThreadPool(2); 
for (int j = 0; j < 2; j++) 
    es.submit(() -> { 
     String tn = Thread.currentThread().getName(); 
     for (int i = 0; i < 2; i++) 
      x.enqueue("v" + i); 

     for (int i = 0; i < 2; i++) 
      System.out.println(tn + " deq: " + x.dequeue()); 
    }); 

が出力（あなたがremove方法にNoSuchElementException秒に起因するnull秒が表示されます）のようになります：ここでの挙動を示すように、単純な「テストケース」だ

pool-1-thread-2 deq: v0 
pool-1-thread-1 deq: null 

最も単純このための解決方法は、LinkedListをjava.util.concurrent.ConcurrentLinkedQueueに置き換えることです。