Java线程池的简单使用方法实例教程

下面我们先来介绍一下Java线程池的概念和作用。

Java线程池是为了解决频繁创建和销毁线程带来的性能开销问题而设计的。线程池会事先创建一定数量的线程，并维护一个任务队列，当有任务需要执行时，就将任务放入队列中。线程池中的线程会不断的从队列中取出任务并执行，执行完后将线程归还给线程池，这样就避免了反复创建和销毁线程的开销。

接下来，我们将介绍Java线程池的简单使用方法实例教程。

创建线程池

Java线程池的创建可以通过Executors工具类的静态方法来实现，常用的方法有三个：

// 创建一个固定线程数的线程池
ExecutorService executorService = Executors.newFixedThreadPool(int nThreads);

// 创建一个单线程线程池
ExecutorService executorService = Executors.newSingleThreadExecutor();

// 创建一个可扩展线程数的线程池
ExecutorService executorService = Executors.newCachedThreadPool();

以上三种方法中，newFixedThreadPool和newSingleThreadExecutor方法创建的线程池是固定大小的线程池，newCachedThreadPool方法创建的线程池大小可自动扩展。

提交任务

任务的提交可以通过execute方法或submit方法来实现，execute方法用于提交没有返回值的Runnable任务，submit方法用于提交带返回值的Callable任务。示例如下：

import java.util.concurrent.*;

public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        // 提交Runnable任务
        executorService.execute(() -> {
            System.out.println("Thread name: " + Thread.currentThread().getName() + " is running.");
        });

        // 提交Callable任务
        Future<String> futureTask = executorService.submit(() -> {
            return "Thread name: " + Thread.currentThread().getName() + " is running.";
        });

        try {
            // 获取Callable任务的返回值
            String result = futureTask.get();
            System.out.println(result);
        } catch (ExecutionException | InterruptedException e) {
            e.printStackTrace();
        }

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

以上是Java线程池的简单使用方法实例教程，希望对您有所帮助。

阅读剩余 23%