server/Queue/Producer.java

class Producer extends Thread {
    
    public Producer(Queue queue, long sleepTime) {
        _queue = queue;
        _sleepTime = sleepTime;
    }
    
    public void run() {
        int count = 0;
        while(true) {
            try { Thread.sleep(_sleepTime); } catch(Exception e) {}
            _queue.add("Object number "+count);
            count ++;
            if(count % 10 == 0) {
                System.out.println(_queue.status());
            }
        }
    }
    
    private Queue _queue;
    private long _sleepTime;
    
}
Revision:	1.2
Committed:	Thu Dec 28 03:49:42 2000 UTC (23 years, 11 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	}