자바 여러 스레드가 하나 개의 필드에

Question

안녕 작업 I 다음 코드 조각이 :

public Item get(int id) 
{ 
    Item i = null; 
    for(Worker w : workers) 
    { 
     w.get(id, i); // Several threads start reading that item from data sources 
    } 
    while(i == null) // Loop until item is found 
    { 
     // this.pause(); there should be a pause but it's not a thread, so I can't do it. 
    } 
    return i; 
} 

내가 더 나은 방법이 있어야한다고 생각, 그 빈 루프 않고 있습니다.

get 기능을 일시 중지하고 작업자 중 한 사람이 알림 만 다시 시작하는 것과 관련된 문제입니다.

Answer 1

여기에서 BlockingQueue을 사용할 수 있습니다. 대기열의 인스턴스를 만듭니다. 그리고 그것을 모든 노동자들에게 전하십시오. 작업자가 항목을 찾으면 대기열에 추가합니다. 그리고 당신은 큐가 비어 있지 때까지 기다립니다 큐가 비어있는 경우에만 그들이 항목을 추가 노동자

public Item get(int id) { 
    BlockingQueue<Item> queue = new ArrayBlockingQueue<Item>(1); 
    for(Worker w : workers) { 
     w.get(id, queue); // Several threads start reading that item from data sources 
    } 
    return queue.take(); 
} 

사용 queue.offer(foundItem); 있도록.