线程池小程序（Java） - JAVA

[java]
//固定大小的线程池
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadTest {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
//创建一个可重用固定线程数的线程池
ExecutorService pool=Executors.newFixedThreadPool(2);
//创建实现了Runnable接口对象，Thread的对象相应也实现了Runnable接口
Thread t1=new MyThread();
Thread t2=new MyThread();
Thread t3=new MyThread();
Thread t4=new MyThread();
Thread t5=new MyThread();
//将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
//关闭线程池
pool.shutdown();

}

}
class MyThread extends Thread
{
public void run()
{
System.out.println(Thread.currentThread().getName()+"····正在运行");
}

}
//创建一个使用单个worker线程的Executor与可重用固定个数线程数的线程池只改了一行代码
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadTest2 {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
//创建一个可重用单个线程数的线程池
ExecutorService pool=Executors.newSingleThreadExecutor();
//创建实现了Runnable接口对象，Thread的对象相应也实现了Runnable接口
Thread t1=new MyThread2();
Thread t2=new MyThread2();
Thread t3=new MyThread2();
Thread t4=new MyThread2();
Thread t5=new MyThread2();
//将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);

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

}

}
class MyThread2 extends Thread
{
public void run()
{
System.out.println(Thread.currentThread().getName()+"····正在运行");
}

}
//创建一个可变尺寸的线程池只改一下pool的创建方式即可
//创建一个可根据需要创建新线程的线程池但是在以前构造的的线程可用时将重用他们
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadTest3 {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
//创建一个可重用单个线程数的线程池
ExecutorService pool=Executors.newCachedThreadPool();
//创建实现了Runnable接口对象，Thread的对象相应也实现了Runnable接口
Thread t1=new MyThread4();
Thread t2=new MyThread4();
Thread t3=new MyThread4();
Thread t4=new MyThread4();
Thread t5=new MyThread4();
//将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
//关闭线程池 www.2cto.com
pool.shutdown();

}

}
class MyThread3 extends Thread
{
public void run()
{
System.out.println(Thread.currentThread().getName()+"····正在运行");
}

}
//自定义线程池

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadTest4 {

线程池小程序（Java）(一)