良いスレッドキュー

import java.util.LinkedList;

public class WorkQueue {

	private final int nThreads;//  
	private final PoolWorker[] threads;//  
	private final LinkedList<Runnable> queue;//  

	public WorkQueue(int nThreads) {
		this.nThreads = nThreads;
		queue = new LinkedList<Runnable>();
		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 (RuntimeException e) {
					// You might want to log something here
				}
			}
		}
	}

	public static void main(String args[]) {
		WorkQueue wq = new WorkQueue(1);// 10 
		Mytask r[] = new Mytask[5];// 20 

		for (int i = 0; i < 5; i++) {
			r[i] = new Mytask();
			wq.execute(r[i]);
		}
	}
}

class Mytask implements Runnable {//  
	public void run() {
		String name = Thread.currentThread().getName();
		try {
			Thread.sleep(5000);//  
		} catch (InterruptedException e) {
		}
		System.out.println(name + " executed OK");
	}

}