高性能计算在Java中的实现：并行计算案例解析-蒲公英云

高性能计算在Java中的实现：并行计算案例解析

原创小灰灰 2024-10-13 23:33 162阅读 0赞

在Java中，我们可以利用Java的并发机制（如多线程、Fork/Join框架等）来实现高性能计算的并行计算。

以下是一个简单的并行计算案例，使用Java的ExecutorService进行任务分发：

import java.util.concurrent.*;
public class ParallelComputingExample {
    private static final int NUM_THREADS = 4; // 设置线程数量
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(NUM_THREADS);
        // 定义任务
        List<Runnable> tasks = new ArrayList<>();
        for (int i = 0; i < 100; i += 2) { // 这是一个简单的计算任务
            tasks.add(new CalculateTask(i));
        }
        // 执行任务
        executor.invokeAll(tasks);
        // 关闭线程池
        executor.shutdown();
    }
    static class CalculateTask implements Runnable {
        private int taskId;
        public CalculateTask(int taskId) {
            this.taskId = taskId;
        }
        @Override
        public void run() {
            System.out.println("Task " + taskId + " is being processed...");
            // 这里是你的计算逻辑，例如加法、乘法等
            try {
                Thread.sleep(2000); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}