server/Queue/Consumer.java

class Consumer extends Thread {
    
    public Consumer(Queue queue) {
        _queue = queue;
    }
    
    public void run() {
        while(true) {
            try { Thread.sleep(1000); } catch(Exception e) {}
            String s = (String) _queue.get();
            System.out.println(s);
        }
    }
    
    private Queue _queue;
    
}
Revision:	1.1
Committed:	Thu Dec 28 01:02:07 2000 UTC (23 years, 4 months ago) by tdb
Branch:	MAIN
Log Message:	A 'consumer' for testing purposes. Takes a String from a Queue and prints it.
#	Content
1	class Consumer extends Thread {
2
3	public Consumer(Queue queue) {
4	_queue = queue;
5	}
6
7	public void run() {
8	while(true) {
9	try { Thread.sleep(1000); } catch(Exception e) {}
10	String s = (String) _queue.get();
11	System.out.println(s);
12	}
13	}
14
15	private Queue _queue;
16
17	}