Java函数：如何使用多线程实现并行计算和任务调度？

在Java中实现多线程并行计算和任务调度可以通过多种方式进行，下面将介绍其中两种常用的方法。

方法一：使用Thread类和Runnable接口

1. 创建一个实现Runnable接口的任务类，该类包含需要并行执行的计算逻辑。

2. 在任务类中实现run()方法，在该方法中编写具体的计算逻辑。

3. 在主类中创建多个Thread对象，并将任务类对象作为参数传递给Thread的构造函数。

4. 调用Thread对象的start()方法启动线程，实现并行计算。

例如，以下是一个简单的示例代码：

public class MyTask implements Runnable {
    private int taskId;

    public MyTask(int taskId) {
        this.taskId = taskId;
    }

    @Override
    public void run() {
        System.out.println("开始执行任务 " + taskId);
        // 执行具体的计算逻辑
        // ...
        System.out.println("任务 " + taskId + " 执行完成");
    }
}

public class Main {
    public static void main(String[] args) {
        for (int i = 0; i < 10; i++) {
            Thread thread = new Thread(new MyTask(i));
            thread.start();
        }
    }
}

在这个示例中，我们创建了10个任务对象，每个任务对象都会在一个新的线程中执行，并且任务之间是并行进行的。

方法二：使用ExecutorService和Callable接口

1. 创建一个实现Callable接口的任务类，该类包含需要并行执行的计算逻辑，并且返回一个计算结果。

2. 在主类中创建一个ExecutorService对象，通过调用它的submit()方法来提交任务。

3. 调用ExecutorService对象的shutdown()方法来关闭线程池。

以下是一个示例代码：

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class MyTask implements Callable<String> {
    private int taskId;

    public MyTask(int taskId) {
        this.taskId = taskId;
    }

    @Override
    public String call() throws Exception {
        System.out.println("开始执行任务 " + taskId);
        // 执行具体的计算逻辑
        // ...
        System.out.println("任务 " + taskId + " 执行完成");
        return "任务 " + taskId + " 的结果";
    }

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5);
        List<Future<String>> resultList = new ArrayList<>();

        for (int i = 0; i < 10; i++) {
            Future<String> future = executorService.submit(new MyTask(i));
            resultList.add(future);
        }

        executorService.shutdown();

        for (Future<String> future : resultList) {
            try {
                System.out.println(future.get());
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
}

在这个示例中，我们使用了ExecutorService创建了一个大小为5的线程池，然后提交了10个任务对象。通过调用submit()方法，任务对象会被提交到线程池中的一个空闲线程进行执行，并且每个任务都会返回一个Future对象，可以通过调用Future对象的get()方法来获取任务的返回结果。

总结来说，以上两种方法都可以实现Java多线程的并行计算和任务调度。选择合适的方法取决于具体应用的需求和场景。