Java 병렬 프로그래밍에서 ExecutorService 및 FutureTask 사용

ExecutorService를 사용하여 스레드 풀을 관리하고 작업을 실행하며, FutureTask를 사용하여 비동기적으로 작업을 실행하고 결과를 검색합니다. ExecutorService는 Executor(), submit() 등의 메소드를 제공하고, FutureTask는 get(), isDone(), cancel() 메소드를 제공한다. 실제 예에서는 이를 사용하여 피보나치 수열의 숫자를 병렬로 계산하는 방법을 보여줍니다.

Java 병렬 프로그래밍에서 ExecutorService 및 FutureTask 사용

소개

ExecutorService 및 FutureTask는 Java 병렬 프로그래밍에 유용한 도구입니다. ExecutorService를 사용하면 일련의 스레드를 관리할 수 있고 FutureTask를 사용하면 작업을 비동기적으로 실행하고 결과를 검색할 수 있습니다.

ExecutorService

ExecutorService는 실행 가능한 스레드 작업 모음을 나타내는 인터페이스입니다. 다음을 사용하여 ExecutorService의 다양한 구현을 생성할 수 있습니다.

ExecutorService executorService = Executors.newFixedThreadPool(5);

여기서 5는 스레드 풀의 스레드 수를 나타냅니다.

ExecutorService는 작업을 실행하기 위해 다음과 같은 메서드를 제공합니다.

• execute(Runnable task): Runnable 작업을 실행합니다. execute(Runnable task)：执行一个 Runnable 任务。
• submit(Runnable task)：执行一个 Runnable 任务并返回值。
• submit(Callable<T> task)：执行一个 Callable 任务并返回值。

FutureTask

FutureTask 是一个 Callable 任务的包装器，它允许您异步执行任务并稍后检索其结果。您可以使用以下方法创建 FutureTask：

FutureTask<String> futureTask = new FutureTask<>(() -> "Hello, world!");

其中，() -> "Hello, world!" 是要执行的 Callable 任务。

FutureTask 提供以下方法来检索任务结果：

• get()：阻塞等待任务完成并返回结果。
• isDone()：检查任务是否已完成。
• cancel(boolean mayInterruptIfRunning)
submit(Runnable task): Runnable 작업을 실행하고 값을 반환합니다.

submit(Callable<T> task): Callable 작업을 실행하고 값을 반환합니다.

FutureTask

FutureTask는 작업을 비동기적으로 실행하고 나중에 결과를 검색할 수 있는 호출 가능 작업에 대한 래퍼입니다. 다음 메소드를 사용하여 FutureTask를 생성할 수 있습니다. 🎜

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

class FibonacciTask implements Callable<Long> {

    private int n;

    public FibonacciTask(int n) {
        this.n = n;
    }

    @Override
    public Long call() {
        long a = 0;
        long b = 1;
        for (int i = 0; i < n; i++) {
            long temp = a;
            a = b;
            b = temp + b;
        }
        return a;
    }
}

public class Main {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(4);
        FutureTask<Long>[] tasks = new FutureTask[10];

        // 创建并提交任务
        for (int i = 0; i < 10; i++) {
            tasks[i] = new FutureTask<>(new FibonacciTask(i));
            executorService.submit(tasks[i]);
        }

        // 获取并打印结果
        for (int i = 0; i < 10; i++) {
            try {
                System.out.println("斐波那契数列第 " + i + " 项：" + tasks[i].get());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        // 关闭 ExecutorService
        executorService.shutdown();
    }
}

🎜여기서 () -> "Hello, world!"는 실행할 호출 가능 작업입니다. 🎜🎜FutureTask는 작업 결과를 검색하기 위해 다음 메서드를 제공합니다. 🎜🎜🎜get(): 작업이 완료되기를 기다리는 것을 차단하고 결과를 반환합니다. 🎜🎜isDone(): 작업이 완료되었는지 확인합니다. 🎜🎜cancel(boolean mayInterruptIfRunning): 작업을 취소합니다(가능한 경우). 🎜🎜🎜🎜실용 사례🎜🎜🎜피보나치 수열을 계산하는 프로그램을 생각해 보세요. ExecutorService 및 FutureTask를 사용하여 여러 피보나치 수를 병렬로 계산할 수 있습니다. 🎜rrreee🎜 이 예에서는 ExecutorService를 만들고 10개의 FibonacciTask 작업을 제출했습니다. 각 작업은 피보나치 수열의 숫자를 계산합니다. FutureTask를 사용하면 이러한 작업을 비동기적으로 실행하고 나중에 결과를 얻을 수 있습니다. 🎜

위 내용은 Java 병렬 프로그래밍에서 ExecutorService 및 FutureTask 사용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!