ExecutorService의 그룹 스레드

Question

ExecutorService에서 특정 코스 ID를 처리하는 모든 스레드를 그룹화 한 다음 해당 스레드 ID에서 해당 스레드 ID를 처리하는 다른 스레드를 모두 닫으면 어떻게 처리 할 수 ​​있습니까?

한 스레드 완료 프로세스까지 코스 ID를 처리 할 수있는 스레드 수는 고정되어 있지 않습니다.

업데이트 :

그래서 어떤 스레드가이 과정을 처리하기 위해 입력, 나는 정적 컬렉션에 추가 할 예정이다.

는 코스 상태가 완료 참조 thread1 그런 다음 한 번, thread1이 진행되는 동안

List l1 = new ArrayList(); 
l1.add(thread1); 

Map t = new Hashmap(); 
t.add("courseid1":l1) 

그래서 다른 스레드가 courseid1을 처리하기 위해 오는, 처음 thread1 처리, courseid1에 대한

l1.add(thread2); 

을 가정 나는 목록 l1에있는 모든 쓰레드에 성공을 보낼 것이다.

Answer 1

나는 parallelStream을 사용합니다.이 작업이 실패하거나 첫 번째 결과를 원할 경우 모든 작업이 중지됩니다.

Optional<Result> res = tasks.parallelStream().map(t -> process(t)).findFirst();