下面是线程池的测试程序
//ThreadPoolTest.java
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader;
import polarman.threadpool.ThreadPool; import polarman.threadpool.ThreadTask;
public class ThreadPoolTest ...{
public static void main(String[] args) ...{ System.out.println(""quit" 退出"); System.out.println(""task A 10" 启动任务A，时长为10秒"); System.out.println(""size 2" 设置当前线程池大小为2"); System.out.println(""max 3" 设置线程池最大线程数为3"); System.out.println();
final ThreadPool pool = new ThreadPool(3, 2); pool.init();
Thread cmdThread = new Thread()...{ public void run()...{
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
while(true)...{ try ...{ String line = reader.readLine(); String words[] = line.split(" "); if(words[0].equalsIgnoreCase("quit"))...{ System.exit(0); }else if(words[0].equalsIgnoreCase("size") && words.length >= 2)...{ try...{ int size = Integer.parseInt(words[1]); pool.setPoolSize(size); }catch(Exception e)...{
}
}else if(words[0].equalsIgnoreCase("max") && words.length >= 2)...{ try...{ int max = Integer.parseInt(words[1]); pool.setMaxPoolSize(max); }catch(Exception e)...{
}
}else if(words[0].equalsIgnoreCase("task") && words.length >= 3)...{ try...{ int timelen = Integer.parseInt(words[2]); SimpleTask task = new SimpleTask(words[1], timelen * 1000); pool.processTask(task); }catch(Exception e)...{
}
}
} catch (IOException e) ...{ e.printStackTrace();
}
}
}
};
cmdThread.start();
/**//*
for(int i=0; i<10; i++){
SimpleTask task = new SimpleTask("Task" + i, (i+10)*1000); pool.processTask(task);
}*/
}
}
class SimpleTask implements ThreadTask...{
private String taskName;
private int timeLen;
public SimpleTask(String taskName, int timeLen)...{ this.taskName = taskName; this.timeLen = timeLen;
}
public void run() ...{ System.out.println(Thread.currentThread().getId() +
": START TASK "" + taskName + """);
try ...{ Thread.sleep(timeLen); } catch (InterruptedException e) ...{
}
System.out.println(Thread.currentThread().getId() +
": END TASK "" + taskName + """);
}
}
使用此线程池相当简单，下面两行代码初始化线程池：
ThreadPool pool = new ThreadPool(3, 2); pool.init();
要处理的任务实现ThreadTask...接口即可（如测试代码里的SimpleTask），这个接口只有一个方法run()
两行代码即可调用：
ThreadTask task = ... //实例化你的任务对象pool.processTask(task);
责任编辑：小草
