Java Runnable线程池使用方法

在Java中，Runnable接口和线程池一起使用可以有效地管理多线程任务。线程池允许你重用一组固定数量的线程来执行多个任务，这样可以减少线程创建和销毁的开销，提高应用程序的性能。

以下是使用Java Runnable接口和线程池的基本步骤：

1. 导入必要的包：

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

2. 创建一个实现Runnable接口的类：

class MyTask implements Runnable {
    private int id;

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

    @Override
    public void run() {
        System.out.println("Task " + id + " is running on thread " + Thread.currentThread().getName());
    }
}

3. 创建一个线程池：

ExecutorService executor = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池

4. 将Runnable任务提交给线程池：

for (int i = 0; i < 10; i++) {
    MyTask task = new MyTask(i);
    executor.submit(task); // 将任务提交给线程池
}

5. 关闭线程池：

executor.shutdown(); // 关闭线程池，不再接受新的任务

完整的示例代码如下：

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

class MyTask implements Runnable {
    private int id;

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

    @Override
    public void run() {
        System.out.println("Task " + id + " is running on thread " + Thread.currentThread().getName());
    }
}

public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池

        for (int i = 0; i < 10; i++) {
            MyTask task = new MyTask(i);
            executor.submit(task); // 将任务提交给线程池
        }

        executor.shutdown(); // 关闭线程池，不再接受新的任务
    }
}

在这个示例中，我们创建了一个固定大小为5的线程池，并提交了10个任务。线程池会自动管理这些任务的执行，确保最多只有5个任务同时运行。最后，我们调用shutdown()方法来关闭线程池。