consumer.java

来自「基于netbeans的java桌面应用程序合集」· Java 代码 · 共 32 行

package com.sun.tiger.concurrency;

import java.io.PrintStream;
import java.util.concurrent.BlockingQueue;

public class Consumer extends Thread {
    
    private BlockingQueue q;
    private PrintStream out;
    
    public Consumer(String name, BlockingQueue q,
            PrintStream out) {
        setName(name);
        this.q = q;
        this.out = out;
    }
    
    public void run() {
        try {
            while (true) {
                process(q.take());
            }
        } catch (InterruptedException e) {
            out.printf("%s interrupted: %s", getName(), e.getMessage());
        }
    }
    
    private void process(Object obj) {
        out.printf("%s processing object:%n         '%s'%n",
                getName(), obj.toString());
    }
}