server/Queue/Consumer.java

class Consumer extends Thread {
    
    public Consumer(Queue queue, long sleepTime, int repititions) {
        _queue = queue;
        _sleepTime = sleepTime;
        _repititions = repititions;
    }
    
    public void run() {
        boolean run = true;
        _n = _queue.getQueue();
        System.out.println("Got queue: "+_n);
        String s = null;
        int i = 0;
        while(run) {
            try { Thread.sleep(_sleepTime); } catch(Exception e) {}
            try {
                s = (String) _queue.get(_n);
            }
            catch(InvalidQueueException e) {
                System.out.println(e);
                run=false;
            }
            System.out.println("["+_n+"] "+s);
            i++;
            if(i==_repititions) {
                run = false;
            }
        }
        System.out.println("Closing down, and releasing queue "+_n);
        _queue.removeQueue(_n);
    }
    
    private Queue _queue;
    private int _n;
    private long _sleepTime;
    private int _repititions;
    
}
Revision:	1.3
Committed:	Tue Jan 2 01:54:19 2001 UTC (23 years, 11 months ago) by tdb
Branch:	MAIN
CVS Tags:	PROJECT_COMPLETION, HEAD
Changes since 1.2:	+21 -13 lines
Error occurred while calculating annotation data.
Log Message:	Amendments for the new dynamic queue stuff, and added a shutdown after a given number of repititions.
#	Content
1	class Consumer extends Thread {
2
3	public Consumer(Queue queue, long sleepTime, int repititions) {
4	_queue = queue;
5	_sleepTime = sleepTime;
6	_repititions = repititions;
7	}
8
9	public void run() {
10	boolean run = true;
11	_n = _queue.getQueue();
12	System.out.println("Got queue: "+_n);
13	String s = null;
14	int i = 0;
15	while(run) {
16	try { Thread.sleep(_sleepTime); } catch(Exception e) {}
17	try {
18	s = (String) _queue.get(_n);
19	}
20	catch(InvalidQueueException e) {
21	System.out.println(e);
22	run=false;
23	}
24	System.out.println("["+_n+"] "+s);
25	i++;
26	if(i==_repititions) {
27	run = false;
28	}
29	}
30	System.out.println("Closing down, and releasing queue "+_n);
31	_queue.removeQueue(_n);
32	}
33
34	private Queue _queue;
35	private int _n;
36	private long _sleepTime;
37	private int _repititions;
38
39	}