手把手教你做一个java线程池小例子(3)

建立一个类继承Runnable接口，大概是这样：

public class BelongTo2 implements Runnable {

@Override

public void run() {

try {

//当前线程休眠2秒 当然也可以写业务

System.out.print("东西");

Thread.currentThread().sleep(2000);

System.out.print("\n");

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

然后再

建立一个类 带main方法，大概是这样：

public class Test2 {

public static void main(String[] args) {

//创建定长线程池 大小为5

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);

for(int i=0;i<20;i++){

BelongTo2 th=new BelongTo2();

fixedThreadPool.execute(th);

}

fixedThreadPool.shutdown();

}

}

运行就可以了。

简单介绍一下ExecutorService 这个类创建一个定长线程池，可控制线程最大并发数（后面的参数就是并发线程的数量），超出的线程会在队列中等待。