Java 使用线程池执行多个任务的示例

下面为您详细讲解Java使用线程池执行多个任务的示例攻略。

什么是线程池

线程池是一个线程队列，它可以有效地控制线程的创建和销毁，从而避免了频繁创建和销毁线程所带来的性能开销。同时，线程池还可以限制线程的并发数量，保证一定的并发度，从而更加有效地使用系统资源。

如何使用线程池执行多个任务

步骤一：创建线程池

创建线程池需要使用到Java提供的Executors类，该类提供了许多静态工厂方法用于创建不同类型的线程池，例如：

// 创建一个固定大小的线程池，线程数量为3
ExecutorService executorService = Executors.newFixedThreadPool(3);

步骤二：创建任务

创建任务需要实现Runnable接口，例如：

public class MyTask implements Runnable {
    @Override
    public void run() {
        // 任务具体执行逻辑
    }
}

步骤三：提交任务

提交任务使用ExecutorService的submit方法，例如：

// 提交任务
executorService.submit(new MyTask());

步骤四：关闭线程池

使用完线程池后，需要关闭线程池，释放系统资源。可以使用ExecutorService的shutdown方法，例如：

// 关闭线程池
executorService.shutdown();

示例一：执行多个任务

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，线程数量为3
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // 提交5个任务
        for (int i = 1; i <= 5; i++) {
            executorService.submit(new MyTask(i));
        }

        // 关闭线程池
        executorService.shutdown();
    }
}

class MyTask implements Runnable {
    private int taskId;

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

    @Override
    public void run() {
        System.out.println("Task " + taskId + " is running.");
    }
}

输出结果：

Task 1 is running.
Task 2 is running.
Task 3 is running.
Task 4 is running.
Task 5 is running.

示例二：执行多个有返回值的任务

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

public class Main {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，线程数量为3
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // 创建有返回值的任务列表
        List<Future<String>> futures = new ArrayList<>();
        for (int i = 1; i <= 5; i++) {
            Future<String> future = executorService.submit(new MyTask(i));
            futures.add(future);
        }

        // 输出任务返回结果
        for (Future<String> future : futures) {
            try {
                System.out.println(future.get());
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }

        // 关闭线程池
        executorService.shutdown();
    }
}

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

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

    @Override
    public String call() throws Exception {
        return "Task " + taskId + " is running.";
    }
}