public static void main(String[] args) {
String poolName = "test-pool";
int maxThreadSize = 2;
OlibThreadPoolService service = new OlibThreadPoolService(poolName, maxThreadSize);
String key = "testThread";
int threadCount = 5;
for(int i=0; i<threadCount; i++){
TestThread thread = new TestThread();
service.start(thread , key+i);
}
}
public class TestThread extends Thread{
public TestThread(){}
public void run(){
System.out.println("start : "+this.currentThread().getName());
try {Thread.sleep(5000);} catch (InterruptedException e) {}
System.out.println("end : "+this.currentThread().getName());
}
}
start : test-pool-testThread0-0
start : test-pool-testThread1-0
end : test-pool-testThread0-0
end : test-pool-testThread1-0
start : test-pool-testThread2-0
start : test-pool-testThread3-0
end : test-pool-testThread2-0
end : test-pool-testThread3-0
start : test-pool-testThread4-0
end : test-pool-testThread4-0