JAVA FutureTask Runnable 직렬화 문제 및 처리 방법론 질문

Question

안녕하세요. JAVA 응용 프로그램 개발자로 사용자에 따라 대용량 처리가 필요한 프로그램 개발 및 유지보수를 담당하고 있습니다. 추가적인 프로그램을 개발하면서 기존에 사용하던 Thread 방식이 아니라, Executor로 전환했는데요. 사업의 특성상 Executor에서 실행되는 Task 단위 한개 한개가 중요한 정보다 보니, 유실이 생기면 안되는 부분이라 예외 처리 및 종료 로직에 신경을 많이 쓰고 있습니다. 현재 고민되는 부분은 Executor를 종료할때 생기는데요. Java 응용 프로그램이다보니 JVM에 shutdownhook을 등록해서 완전 종료 전 종료 로직을 처리중입니다. @@@ 1. 여기서 Executor를 종료할때 shutdown()을 호출해 이미 submit 된 모든 task를 처리 하고 종료하려니 JVM에 등록된 shutdownHook은 일정 시간이 지나면 강제 종료가 됩니다. 대용량 처리 중 shutdown이 호출되었고, shutdownhook 로직에서 task를 모두 처리하기 전에 종료되면 유실이 생깁니다. 여기서 shutdownhook 호출시 강제 종료되는 시간을 제가 마음대로 조정이 가능할까요? @@@ 2. executor.shutdown() 대신 shutdownNow()를 호출하면 List 을 리턴 받고 Executor는 바로 종료되기 때문에, 빠른 처리가 가능한데요. 여기서 또 문제가 생깁니다. 이 List을 직렬화 하려니, executor에서 리턴해 주는 runnable은 FutureTask를 구현하고 있더군요. 이 FutureTask는 직렬화 대상이 아니라서, Exception이 발생합니다. 일반적으로 Runnable과 Serialze를 구현하는 클래스는 직렬화 가능한 부분을 테스트를 통해 직접 확인했구요. 다만, 여기서 shutdownNow()로 리턴되는 Runnable이 FutureTask를 구현하고 있어서 직렬화가 진행이 되지 않는것 같습니다. 여기서 이 List을 응용 프로그램이 종료 된 후 안전하게 보관하고 있다가 다시 실행시 Task를 가져와 실행할 방법이 있을까요? 상황이 복잡해서 설명이 길어진 점 죄송합니다. 아래는 제가 테스트중인 예제 코드 입니다. public class test { static class t implements Runnable, Serializable { private static final long serialVersionUID = -3494850604742315399L; String name; @Override public void run() { System.out.println(name); Uninterruptibles.sleepUninterruptibly(10, TimeUnit.SECONDS); } } static class se implements Serializable { private static final long serialVersionUID = 6773092030407420311L; List runnableList; } public static void main(String[] args) throws Exception { t a = new t(); a.name = "11"; t b = new t(); b.name = "22"; CustomExecutor customExecutor = new CustomExecutor(1, 1, 10, "TEST", new SenderRejectedExecutionHandlers()); customExecutor.getExecutorService().submit(a); customExecutor.getExecutorService().submit(b); List test = customExecutor.getExecutorService().shutdownNow(); ObjectSerialize.write(test, "C:\aa\TASK-123"); ObjectSerialize.readByte("C:\aa\"); } }

zepinos · Answer

질문에 대한 답을 드리기는 좀 힘들 것 같고, 개인적으로 질문을 보다 생긴 궁금증이 있어서 반대로 질문을 드려봅니다. 1. 유실이라는게, 어떠한 하나의 작업 도중 끊어지면 유실인건가요? 아니면 재시작 시 그 작업을 다시 시작하면 유실이 아닌 건가요? 2. 어짜피 kill signal 이 왔을 때 마지막 작업을 마무리 하려고 하는 것일텐데, SIGKILL (흔히 말하는 kill -9) 이 왔을 때에는 어떻게 하실 계획인가요? 저라면, 1번에서 재시작하면 된다고 했을 때, 별도의 외부 Queue 등 이용해서 작업 목록을 관리할 것 같습니다.

유타키 · Answer

1. 한개의 Task는 로직의 시작부터 로직의 끝까지 all or nothing 입니다. Task 내에서 실행 되어야 할 로직은 모두 실행되어야 하고 아니면 모두 실패 처리가 진행되어야 되구요. 해당 로직은 try catch를 이용해서 내부 작업을 끝내놨습니다. 따라서, Task 한개는 재시작시 그작업을 실행하게 된다면 유실이라고 보지 않습니다. 2. SIGKILL은 강제 종료로 보고 있습니다. SIGKILL이 들어오면 APPLICATION은 준비된 종료 로직을 실행하지 못하게 되므로 응용 프로그램 내부에서 가지고 있던 정보들을 처리하지 못합니다.따라서, SIGKILL은 관여 범위가 아닙니다. 조언 감사합니다.처음 부터 외부 QUEUE 자체를 생각 안해본 건 아니지만 사업 특성상 고객사 서버에 작은 리소스를 가지고 동작하는 프로그램입니다. 따라서 JAVA 응용 프로그램 내에서 모든걸 처리해야 되구요. 프로젝트 자체 조건이 조금 까다로운 면이 있어서, 제한 사항이 많습니다.

JAVA FutureTask Runnable 직렬화 문제 및 처리 방법론 질문

2개의 답변

Q&A 목록