Java ExecutorService에서 시간에 따른 작업 중단을 어떻게 구현할 수 있습니까?

시간 초과로 ExecutorService에서 작업 중단

시간 초과 후 작업 중단을 처리하는 사용자 정의 ExecutorService를 구현하는 것은 어려울 수 있습니다. 그러나 Java 동시성 프레임워크는 ScheduledExecutorService를 사용하여 편리한 솔루션을 제공합니다.

작업 시간 초과를 위한 ScheduledExecutorService

ScheduledExecutorService를 사용하면 지정된 지연 후 또는 주기적으로 실행되도록 작업을 예약할 수 있습니다. 간격. 이 기능을 활용하면 제출된 작업을 모니터링하고 사전 정의된 시간 초과를 초과하는 경우 이를 중단하는 사용자 정의 ExecutorService를 생성할 수 있습니다.

TimeoutThreadPoolExecutor 구현

이러한 작업을 생성하는 한 가지 접근 방식 ExecutorService는 표준 ThreadPoolExecutor를 확장하는 TimeoutThreadPoolExecutor 클래스입니다. ScheduledExecutorService(timeoutExecutor)와 동시 맵(runningTasks)을 통합하여 실행 중인 작업을 추적하고 중단을 예약합니다.

TimeoutThreadPoolExecutor의 기능

• beforeExecute: 작업이 제출되면 timeoutExecutor를 사용하여 중단되도록 예약됩니다. ScheduledFuture가 반환되어 runningTasks에 저장되어 작업을 예약된 중단 작업에 매핑합니다.
• afterExecute: 작업이 완료되면 해당 ScheduledFuture가 runningTasks에서 제거되고 취소되어 작업이 중단됩니다. 아직 완료되지 않은 경우
• 종료: ThreadPoolExecutor와 ScheduledExecutorService를 모두 정상적으로 종료합니다.
• shutdownNow: ThreadPoolExecutor와 ScheduledExecutorService를 모두 강제 종료합니다.

사용

이것을 사용하려면 사용자 정의 ExecutorService를 사용하여 원하는 매개변수로 TimeoutThreadPoolExecutor를 인스턴스화하고 작업 제출을 시작합니다. 작업이 완료되지 않은 경우 지정된 시간 초과 후에 중단됩니다.

일정을 사용하는 대체 방법

ExecutorService에서 장기 실행 작업을 중단하는 또 다른 접근 방식은 다음과 같습니다. ScheduledExecutorService에서 제공하는 스케줄 메소드를 사용합니다. 두 개의 작업을 제출할 수 있습니다. 하나는 실제 작업을 실행하고 다른 하나는 지정된 시간 초과 후 취소합니다.

코드 예

ScheduledExecutorService executor = Executors.newScheduledThreadPool(2); 
Future handler = executor.submit(new Callable(){ ... });
executor.schedule(new Runnable(){
    public void run(){
        handler.cancel();
    }      
}, 10000, TimeUnit.MILLISECONDS);

이 방법을 사용하면 다음을 수행할 수 있습니다. 10초 제한 시간으로 작업을 실행하면 해당 작업이 취소되고 중단됩니다.

위 내용은 Java ExecutorService에서 시간에 따른 작업 중단을 어떻게 구현할 수 있습니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!