作者popcorny (毕业了..@@")
看板java
标题Re: [问题] 关於Executor运作原理
时间Thu Nov 22 11:35:46 2012
: → FrankWOO:二楼大大建议我会去看的 11/22 09:59
: → FrankWOO:三楼大大 我已经看过了 他用ThreadPoolExecutor产生限制 11/22 10:01
: → FrankWOO:Thread数量，但是他怎麽拿取BlockingQueue东西的实作 11/22 10:06
大概长这样吧
//MyExecutor.java
private BlockingQueue<Runnable> queue = ...;
private ThreadFactory factory = ...;
private int numberOfThreads = ...;
public void startSerivce()
{
for(int i=0; i<numberOfThreads; i++)
{
Thread thread = factory.createThread();
thread.start(new Runnable(){
public void run(){
while(!isCancel)
{
// Take task, block until task is available..
Runnalbe task = queue.take();
task.run();
}
}
});
}
}
public void execute(Runnable task)
{
queue.put(task);
}
--
※ 发信站: 批踢踢实业坊(ptt.cc)
◆ From: 220.135.251.162
※ 编辑: popcorny 来自: 220.135.251.162 (11/22 11:38)