?? threadpoolmain.java
字號:
package com.hxyh.sanny.mms.cmcc.base.thread;
import java.io.PrintStream;
public class ThreadPoolMain
{
public ThreadPoolMain()
{
}
public static Runnable makeRunnable(final String name, final long firstDelay)
{
return new Runnable() {
public void run()
{
try
{
System.out.println(String.valueOf(String.valueOf(name)).concat(": starting up"));
Thread.sleep(2000L);
System.out.println(String.valueOf(String.valueOf(name)).concat(": doing some stuff"));
Thread.sleep(firstDelay);
System.out.println(String.valueOf(String.valueOf(name)).concat(": leaving"));
}
catch(InterruptedException ix)
{
System.out.println(String.valueOf(String.valueOf(name)).concat(": got interrupted!"));
return;
}
catch(Exception x)
{
x.printStackTrace();
}
}
public String toString()
{
return name;
}
};
}
public static void main(String args[])
{
try
{
ThreadPool pool = new ThreadPool(20);
pool.setTimeout(5000L);
while (true)
{
Runnable ra = makeRunnable("RA", 1000L);
pool.execute(ra);
Runnable rb = makeRunnable("RB", 1000L);
pool.execute(rb);
Runnable rc = makeRunnable("RC", 2000L);
pool.execute(rc);
Runnable rd = makeRunnable("RD", 1000L);
pool.execute(rd);
Runnable re = makeRunnable("RE", 1000L);
pool.execute(re);
Thread.sleep(10000L);
}
/*
pool.stopRequestIdleWorkers();
Thread.sleep(2000L);
pool.stopRequestIdleWorkers();
Thread.sleep(5000L);
pool.stopRequestAllWorkers();
*/
}
catch(InterruptedException ix)
{
ix.printStackTrace();
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -