class mythread extends Thread{
private String id;
/**
*
*/
public mythread(String id) {
// TODO Auto-generated constructor stub
this.id=id;
}
@Override
public void run() {
System.out.println(id+"\t正在执行...... Time:"+new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));
try {
this.sleep(2*1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(id+"\t关闭...... Time:"+new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));
}
}
public static void main(String[] args) throws Exception {
ThreadPoolExecutor tpe=(ThreadPoolExecutor) Executors.newCachedThreadPool();
while(true){
for (int i = 0; i < 3; i++) {
String id=UUID.nameUUIDFromBytes((i+"").getBytes()).toString();
tpe.execute(new mythread(id));
}
System.out.println("当前线程数为:"+tpe.getPoolSize());
Thread.sleep(1000);
}
}