Revision: | 1.2 |
Committed: | Thu Dec 28 03:49:42 2000 UTC (23 years, 10 months ago) by tdb |
Branch: | MAIN |
CVS Tags: | PROJECT_COMPLETION, HEAD |
Changes since 1.1: | +4 -2 lines |
Log Message: | Added a changeable sleep time. |
# | Content |
---|---|
1 | class Producer extends Thread { |
2 | |
3 | public Producer(Queue queue, long sleepTime) { |
4 | _queue = queue; |
5 | _sleepTime = sleepTime; |
6 | } |
7 | |
8 | public void run() { |
9 | int count = 0; |
10 | while(true) { |
11 | try { Thread.sleep(_sleepTime); } catch(Exception e) {} |
12 | _queue.add("Object number "+count); |
13 | count ++; |
14 | if(count % 10 == 0) { |
15 | System.out.println(_queue.status()); |
16 | } |
17 | } |
18 | } |
19 | |
20 | private Queue _queue; |
21 | private long _sleepTime; |
22 | |
23 | } |