Java自带线程池

package thread;

import org.junit.Test;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
* Created by guofeipeng on 15/11/17.
* 线程池测试
*/
public class TestThreadPool {

@Test
public void testThradPool(){
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(30, 50, 60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
for(int i = 0 ; i < 10 ; i++){
Thread t = new Thread(new Task());
t.setName("thread" + i);
threadPoolExecutor.execute(t);
}
threadPoolExecutor.shutdown();
while (!threadPoolExecutor.isTerminated()) {

}
}

class Task implements Runnable{
@Override
public void run() {
System.out.println("task " + Thread.currentThread().getName());
}
}
}