会python真的可以为所欲为0(回)
381天前
这里还有人吗1(回)
567天前这里还有人吗0(回)
567天前
每天面对着电脑屏幕，敲打键盘。我所面对的并不只是代码，而是一种生活方式。0(回)
791天前到处都是羊，不想上班0(回)
871天前
鸽子
0(回)
875天前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 < nThreads; 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 (Exception e) { |
// TODO: handle exception |
} |
} |
} |
} |
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 (Exception e) { |
// TODO: handle exception |
} |
System.out.println(name + " executed OK"); |
} |
} |
