java如何让代码并行

51次阅读

共计 885 个字符，预计需要花费 3 分钟才能阅读完成。

可以通过使用 Java 中的多线程来实现代码的并行执行。以下是一些实现并行代码的方法：

使用 Thread 类：创建多个 Thread 对象，并将需要并行执行的代码放在 run 方法中。然后使用 start 方法启动线程，使它们并行执行。

Thread thread1 = new Thread(() -> {// 并行执行的代码 
});
Thread thread2 = new Thread(() -> {// 并行执行的代码 
});

thread1.start();
thread2.start();

使用 ExecutorService：创建一个 ExecutorService 对象，然后使用 submit 方法将需要并行执行的代码包装成一个 Runnable 对象提交给 ExecutorService。ExecutorService 会自动管理线程的创建和销毁，并发执行提交的任务。

ExecutorService executorService = Executors.newFixedThreadPool(2);

executorService.submit(() -> {// 并行执行的代码 
});

executorService.submit(() -> {// 并行执行的代码 
});

executorService.shutdown();  // 关闭 ExecutorService

使用 Fork/Join 框架：Fork/Join 框架是 Java 提供的用于并行计算的机制。它将任务划分为更小的子任务，并将子任务分配给不同的线程执行。使用 Fork/Join 框架，可以方便地实现代码的并行执行。

class MyTask extends RecursiveAction {@Override
    protected void compute() {// 并行执行的代码 
    }
}

ForkJoinPool forkJoinPool = new ForkJoinPool();
MyTask myTask = new MyTask();

forkJoinPool.invoke(myTask);