ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/experimental/server/Queue/Consumer.java
Revision: 1.3
Committed: Tue Jan 2 01:54:19 2001 UTC (23 years, 3 months ago) by tdb
Branch: MAIN
CVS Tags: PROJECT_COMPLETION, HEAD
Changes since 1.2: +21 -13 lines
Log Message:
Amendments for the new dynamic queue stuff, and added a shutdown after a
given number of repititions.

File Contents

# 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 }