Java : 비동기 작업에서 검색된 결과 주문

Question

결과를 정확한 순서로 요구하는 계산 (CTR 암호화)이 있습니다.

이 결과를 계산하는 멀티 스레드 디자인을 만들었습니다.이 경우 결과는 ByteBuffer입니다. 물론 계산 자체는 비동기 적으로 실행되므로 언제든지 어떤 순서로든 결과를 사용할 수 있습니다. "사용자"는 메서드를 호출하여 결과를 사용하는 단일 스레드 응용 프로그램이며, 그 후에 메서드는 ByteBuffers를 리소스 풀로 반환합니다. 리소스 관리는 이미 스레드 안전 스택을 사용하여 처리됩니다.

이제 질문 : 결과를 취합하여 오른쪽 순서에서 사용할 수있는 것이 필요합니다. 다음 결과를 사용할 수 없으면 사용자가 호출 한 메서드가있을 때까지 차단해야합니다. 누구든지 비동기 적으로 계산 된 결과를 순서대로 반환 할 수있는 java.util.concurrent의 좋은 전략이나 클래스를 알고 있습니까?

솔루션은 스레드로부터 안전해야합니다. 제 3 자 라이브러리 인 Thread.sleep()/Thread.wait()를 피하고 "synchronized"가 아닌 다른 관련 키워드를 피하고 싶습니다. 더구나, 작업은 예를 들어. 필요하다면 집행자를 올바른 순서로 선택하십시오. 이것은 연구용이므로 Java 1.6 또는 1.7 구조를 자유롭게 사용할 수 있습니다.

참고 : JRE 및 [암호화]에 정의 된 클래스 내에서 누군가가 이미 처리해야 할 수도 있으므로이 질문 [jre]에 태그를 지정했지만 질문 자체는 순전히 Java에 관한 것입니다. & 멀티 스레딩.

Answer 1

사용 executors framework 다음 listOfCallables 당신이 데이터에서 작동하도록 만들어 가지고 List<Callable<ByteBuffer>> 될 것

ExecutorService executorService = Executors.newFixedThreadPool(5); 
List<Future> futures = executorService.invokeAll(listOfCallables); 
for (Future future : futures) { 
    //do something with future.get(); 
} 
executorService.shutdown(); 

. 예를 들면 :

list.add(new SubTaskCalculator(1, 20)); 
list.add(new SubTaskCalculator(21, 40)); 
list.add(new SubTaskCalculator(41, 60)); 

(숫자의 임의의 범위 조정이 손에 당신의 작업에) 결과가 완료,하지만 동시에 다른 작업도 그렇게 때를, 실행 때까지

.get() 블록 도달하면 .get()이 준비됩니다.

Answer 2

올바른 순서로 결과를 반환하는 것은 간단합니다. 각 결과가 도착하면 arraylist에 저장하고 일단 모든 결과를 얻으면 arraylist를 정렬하십시오. PriorityQueue를 사용하여 결과가 도착했을 때 항상 정렬 된 상태로 유지할 수는 있지만, 결과에 아무런 영향을 미치지 않기 때문에 아무 일도하지 않아도됩니다.

그래서, 당신이 할 수있는 것은 이것이다 :

들이 서수으로 분류 할 수 있도록, 당신의 bytearrays와 서수 중 하나를 포함하는 "WorkItem에서"클래스를 선언합니다.당신의 메인 쓰레드에서

...do work and produce a work_item... 

synchronized(LockObject) 
{ 
    ResultList.Add(work_item); 
    number_of_results++; 
    LockObject.notifyAll(); 
} 

같은 것을 수행합니다 : 작업 스레드에서

은 같은 것을 할 당신이 원하는에 대한 이해를 확보 한 후

synchronized(LockObject) 
    while(number_of_results != number_of_items) 
     LockObject.wait(); 
ResultList.Sort(); 
...go ahead and use the results... 

Answer 3

내 새로운 답을 해야 할 일 :

바이트 수와 그 서수 중 하나가 포함 된 "WorkItem"클래스를 선언하여 서수로 정렬 할 수 있도록합니다.

서수로 정렬 된 java.util.PriorityQueue를 사용합니다. 기본적으로 우선 순위 대기열의 첫 번째 항목은 주어진 시간에 처리 할 다음 항목이됩니다.

각 작업 스레드는 PriorityQueue에 결과를 저장하고 일부 잠금 개체에 NotifyAll을 발급합니다.

주 스레드가 잠금 개체를 기다렸다가 큐에 항목이 있고 큐의 첫 번째 항목 (peeked, dequeued)의 서수가 지금까지 처리 된 항목 수와 같은 경우 , 항목을 대기열에서 제외하고 처리합니다. 그렇지 않다면, 그것은 계속 기다리고 있습니다. 모든 항목이 생성되고 처리되면 완료됩니다.