Java并行编程中的ExecutorService和FutureTask的使用

利用 executorservice 管理线程池并执行任务,使用 futuretask 异步执行任务并检索其结果。executorservice 提供了 execute()、submit() 等方法,futuretask 提供了 get()

利用 executorservice 管理线程池并执行任务,使用 futuretask 异步执行任务并检索其结果。executorservice 提供了 execute()、submit() 等方法,futuretask 提供了 get()、isdone()、cancel() 方法。通过实战案例展示了如何使用它们并行计算斐波那契数列中的数字。

Java并行编程中的ExecutorService和FutureTask的使用

Java 并行编程中的 ExecutorService 和 FutureTask 的使用

简介

ExecutorService 和 FutureTask 是 Java 中进行并行编程的有用工具。ExecutorService 允许您管理一组线程,而 FutureTask 允许您异步执行任务并检索其结果。

ExecutorService

ExecutorService 是一个接口,它表示一个可执行线程任务的集合。您可以使用以下方法创建 ExecutorService 的不同实现:

ExecutorService executorService = Executors.newFixedThreadPool(5);

登录后复制

其中,5 表示线程池中的线程数。

ExecutorService 提供以下方法来执行任务:

  • 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):取消任务(如果可能)。

实战案例

考虑一个计算斐波那契数列的程序。我们可以使用 ExecutorService 和 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();
    }
}

登录后复制

在这个例子中,我们创建了一个 ExecutorService 并提交了 10 个 FibonacciTask 任务。每个任务计算斐波那契数列中的一个数字。使用 FutureTask,我们能够异步执行这些任务并稍后获取其结果。

以上就是Java并行编程中的ExecutorService和FutureTask的使用的详细内容,更多请关注叮当号网其它相关文章!

文章来自互联网,只做分享使用。发布者:叮当,转转请注明出处:https://www.dingdanghao.com/article/367306.html

(0)
上一篇 2024-04-18 10:00
下一篇 2024-04-18 10:00

相关推荐

联系我们

在线咨询: QQ交谈

邮件:442814395@qq.com

工作时间:周一至周五,9:30-18:30,节假日休息

关注微信公众号