线程池的代码实现

142 阅读 0 评论 94 点赞

我是靠谱客的博主矮小冷风，这篇文章主要介绍线程池的代码实现，现在分享给大家，希望可以做个参考。

Executors：线程池的工厂类，用来生成线程池

里面的静态方法：

static ExecutorService newFixedThreadPool（int nThreads）创建要给可重用固定线程数的线程池

参数：

int nThreads：创建线程池中包含的线程数量

返回值：

ExcutorService接口，返回的是ExcutorService接口的实现类对象，可以使用ExcutorService接口来接受（面向接口编程）

ExcutorService：线程池接口

用来从线程池中获取线程，调用start方法，执行线程任务：

submit（runnable task）提交一个Runnable任务用于执行。

关闭/销毁线程池的方法：

void shutdown（）。

线程池的使用步骤：

1使用线程池工厂类Excutors里面提供的静态方法newFixedThreadpool生产一个指定线程数量的线程池

2创建一个类，实现Runnable接口，重写run方法，设置线程任务

3.调用ExecutorService中的方法submit，传递线程任务（实现类），开启线程，执行run方法

4.调用ExecutorService中的方法shutdown销毁线程池（不建议执行）。

创建Runnable实现类

复制代码

1
2
3
4
5
6
7
8
9
public class FuXi3 implements Runnable  {

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+"线程创建成功");
    }
}

开始测试

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class FuXi2 {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(10);//多态创建一个指定数量的线程池
        FuXi3 fuXi3  = new FuXi3();
        executorService.submit(fuXi3);//传递一个线程类接下来执行线程类里面的run方法
        executorService.submit(fuXi3);//传递一个线程类接下来执行线程类里面的run方法
        executorService.submit(fuXi3);//传递一个线程类接下来执行线程类里面的run方法
        executorService.submit(fuXi3);//传递一个线程类接下来执行线程类里面的run方法
        executorService.shutdown();//关闭线程池

    }
    }