package com.lesson.threadpool.example;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class ThreadPoolTest {
public static void main(String[] args) {
//创建三个线程池
ExecutorService threadPool =
Executors.newFixedThreadPool(3);
Executors.newFixedThreadPool(3);
// Executors.newCachedThreadPool();
for (int i = 1; i <= 10; i++) {
final int task = i;
threadPool.execute(new Runnable() {
public void run() {
//..
for (int j = 1; j <= 10; j++) {
try {
Thread.sleep(20);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()
+ "is loop of " + j + " for task
" + task);
}
}
});
}
System.out.println("all of 10 tasks have committed");
// threadPool.shutdown();//shutdownNow();
//....
Executors.newScheduledThreadPool(3).scheduleAtFixedRate(new
Runnable() {
Runnable() {
public void run() {
System.out.println("bombing");
}
}, 6, 2, TimeUnit.SECONDS);
}
}