当前页面: 开发资料首页 → Java 专题 → 线程池与工作队列

线程池与工作队列

摘要: 线程池与工作队列

</td> </tr> <tr> <td width="502" height="35" valign="top" class="ArticleTeitle">import java.util.*;
public class WorkQueue
{
private final int nThreads;//线程池的大小
private final PoolWorker[] threads;//用数组实现线程池
private final LinkedList queue;//任务队列

public WorkQueue(int nThreads){
this.nThreads = nThreads;
queue = new LinkedList();
threads = new PoolWorker[nThreads];

for (int i=0; i threads[i] = new PoolWorker();
threads[i].start();//启动所有工作线程
}
}

public void execute(Runnable r) {//执行任务
synchronized(queue) {
queue.addLast(r);
queue.notify();
}
}

private class PoolWorker extends Thread {//工作线程类
public void run() {
Runnable r;
while (true) {
synchronized(queue) {
while (queue.isEmpty()) {//如果任务队列中没有任务，等待
try{
queue.wait();
}catch (InterruptedException ignored){}
}
r = (Runnable) queue.removeFirst();//有任务时，取出任务
}
try {
r.run();//执行任务
}catch (RuntimeException e) {
// You might want to log something here
}
}
}
}

public static void main(String args[]){
WorkQueue wq=new WorkQueue(10);//10个工作线程
Mytask r[]=new Mytask[20];//20个任务

for(int i=0;i<20;i++){
r[i]=new Mytask();
wq.execute(r[i]);
}
}
}
class Mytask implements Runnable{//任务接口
public void run(){
String name=Thread.currentThread().getName();
try{
Thread.sleep(100);//模拟任务执行的时间
}catch(InterruptedException e){}
System.out.println(name+" executed OK");
}
}
运行结果：

C:\java>java WorkQueue
Thread-1 executed OK
Thread-2 executed OK
Thread-3 executed OK
Thread-4 executed OK
Thread-5 executed OK
Thread-6 executed OK
Thread-7 executed OK
Thread-8 executed OK
Thread-9 executed OK
Thread-10 executed OK
Thread-1 executed OK
Thread-2 executed OK
Thread-3 executed OK
Thread-4 executed OK
Thread-5 executed OK
Thread-6 executed OK
Thread-7 executed OK
Thread-8 executed OK
Thread-9 executed OK
Thread-10 executed OK

function TempSave(ElementID) { CommentsPersistDiv.setAttribute("CommentContent",document.getElementById(ElementID).value); CommentsPersistDiv.save("CommentXMLStore"); } function Restore(ElementID) { CommentsPersistDiv.load("CommentXMLStore"); document.getElementById(ElementID).value=CommentsPersistDiv.getAttribute("CommentContent"); } </td> <td width="182" valign="top" class="ArticleTeitle">
</td> </tr> <tr> <td height="25" colspan="2" valign="top" class="ArticleTeitle">

↑返回目录
前一篇: 异常回调
后一篇: 利用反射进行方法调用