Penggunaan ExecutorService dan FutureTask dalam pengaturcaraan selari Java

Gunakan ExecutorService untuk mengurus kumpulan benang dan melaksanakan tugas, dan gunakan FutureTask untuk melaksanakan tugasan secara tidak segerak dan mendapatkan semula keputusannya. ExecutorService menyediakan kaedah seperti execute() dan submit(), dan FutureTask menyediakan kaedah get(), isDone(), dan cancel(). Contoh praktikal menunjukkan cara menggunakannya untuk mengira nombor dalam jujukan Fibonacci secara selari.

Penggunaan ExecutorService dan FutureTask dalam Java Parallel Programming

Pengenalan

ExecutorService dan FutureTask adalah alatan berguna untuk pengaturcaraan selari. ExecutorService membolehkan anda mengurus satu set utas, manakala FutureTask membenarkan anda melaksanakan tugas secara tak segerak dan mendapatkan semula keputusannya.

ExecutorService

ExecutorService ialah antara muka yang mewakili koleksi tugas urutan boleh laku. Anda boleh membuat pelaksanaan berbeza ExecutorService menggunakan:

ExecutorService executorService = Executors.newFixedThreadPool(5);

di mana 5 mewakili bilangan utas dalam kumpulan benang.

ExecutorService menyediakan kaedah berikut untuk melaksanakan tugas:

• execute(Runnable task): Jalankan tugas 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)
serahkan(Tugas boleh dijalankan): Laksanakan tugasan Boleh Jalan dan kembalikan nilai.

serahkan(Tugas Boleh Panggil): Laksanakan tugasan Boleh Panggil dan kembalikan nilai.

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();
    }
}

Atas ialah kandungan terperinci Penggunaan ExecutorService dan FutureTask dalam pengaturcaraan selari Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!