河床博客

// Create a bounded blocking queue of integers
final int capacity = 10;
BlockingQueue queue = new ArrayBlockingQueue(capacity);
// Create a set of worker threads
final int numWorkers = 2;
Worker[] workers = new Worker[numWorkers];
for (int i=0; i workers[i] = new Worker(queue);
workers[i].start();
}try {
// Add some work to the queue; block if the queue is full.
// Note that null cannot be added to a blocking queue.
for (int i=0; i<100; i++) {
queue.put(i);
}// Add special end-of-stream markers to terminate the workers
for (int i=0; i queue.put(Worker.NO_MORE_WORK);
}
} catch (InterruptedException e) {
}This worker thread removes an integer from the work queue and calculates its square.
class Worker extends Thread {
// Special end-of-stream marker. If a worker retrieves
// an Integer that equals this marker, the worker will terminate.
static final Integer NO_MORE_WORK = new Integer(0);BlockingQueue q;

Worker(BlockingQueue q) {
this.q = q;
}
public void run() {
try {
while (true) {
// Retrieve an integer; block if the queue is empty
Integer x = q.take();

// Terminate if the end-of-stream marker was retrieved
if (x == NO_MORE_WORK) {
break;
}

// Compute the square of x
int y = x * x;
}
} catch (InterruptedException e) {
}
}
}