ExecutorService를 사용해서 Batch를 돌리려고 하는데 어떤 문제가 있는건가요?

Question

int MAX_THREADS = 3 ExecutorService executorService = Executors.newFixedThreadPool(MAX_THREADS); int startIndex = 0; int perThread = items.size() / MAX_THREADS; public void exploreMCCX() throws Exception { for (int i = 0; i < MAX_THREADS -1; i++) { int endIndex = startIndex + perThread; executorService.execute(new Task(sortItems.subList(startIndex, endIndex))); startIndex = endIndex; } executorService.execute(new Task(sortItems.subList(startIndex, items.size()))); do { try { // 종료 요청이 있었는지 체크 if (!executorService.isShutdown()) { log.debug("종료 요청"); // 이미 시작된 Task는 실행 하고, 새로운 작업은 받지 않음 executorService.shutdown(); } } catch (Exception e) { log.warn(e.getMessage()); // 오류로 모든 Task 강제 종료 executorService.shutdownNow(); } // 지정된 시간 별로(10초단위) 작업이 모든 작업이 중지되었는지 체크 작업이 완료되었으면 루프 해제 } while (!executorService.awaitTermination(10, TimeUnit.SECONDS)); executorService.execute(new Task("abc", true)); } -- Task 부분 public class Task implements Runnable { List

집킨 · Answer

오류 메세지가 안보입니다..

ExecutorService를 사용해서 Batch를 돌리려고 하는데 어떤 문제가 있는건가요?

1개의 답변

#batch 목록