ExecutorService를 사용하여 Java에서 스레드에 대한 시간 초과를 설정하는 방법은 무엇입니까?

스레드의 시간 초과 설정 방법

초기 문의에서 제기한 것처럼 스레드의 실행을 어떻게 제한할지에 대한 우려가 있습니다. 시간. 목표는 스레드가 무한 루프에 진입하여 상위 스레드가 무기한 대기하게 되는 상황을 처리하는 것입니다.

논의된 솔루션 중 하나는 스레드의 run() 메서드 내에서 TimerTask를 사용하는 것입니다. 그러나 보다 효율적인 접근 방식은 ExecutorService 클래스를 활용하는 것입니다. 이는 스레드에서 시간 초과를 설정하는 편리한 메커니즘을 제공합니다.

ExecutorService를 사용한 구현 예는 다음과 같습니다.

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class TimeoutTest {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Future<String> future = executor.submit(new Task());

        try {
            System.out.println("Started..");
            System.out.println(future.get(3, TimeUnit.SECONDS));
            System.out.println("Finished!");
        } catch (TimeoutException e) {
            future.cancel(true);
            System.out.println("Terminated!");
        }

        executor.shutdownNow();
    }
}

class Task implements Callable<String> {
    @Override
    public String call() throws Exception {
        Thread.sleep(4000); // Simulate a long-running task that takes 4 seconds
        return "Ready!";
    }
}

이 예에서 Task 클래스는 긴 실행중인 작업. ExecutorService.submit() 메서드는 실행을 위해 이 작업을 제출하는 데 사용됩니다. submit()이 반환한 Future 객체는 작업 결과를 검색하기 위한 메커니즘을 제공합니다.

Future.get() 메서드는 3초의 시간 제한 인수와 함께 호출됩니다. 이 시간 내에 작업이 완료되면 결과가 반환됩니다. 그러나 작업이 3초 이상 소요되면 TimeoutException이 발생합니다. catch 블록에서 작업이 취소되고 "종료되었습니다!" 메시지가 인쇄됩니다.

또한 장기 실행 작업에서는 중단을 처리하기 위한 검사를 통합하여 작업이 무기한 실행되는 것을 방지해야 한다는 점에 유의하는 것이 중요합니다. 이 검사는 Thread.interrupted()를 사용하여 구현할 수 있습니다.

위 내용은 ExecutorService를 사용하여 Java에서 스레드에 대한 시간 초과를 설정하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!