blob: ed6da2251badf318db475b638c82ca6cbfff3714 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
//File: Producer.java
//Seth Widoff 8/8/96
//This class attempts at random intervals to enqueue random elements
//into a queue. If the queue is full the thread waits until an element
//has been dequeued and another thread has invoked the notify() method.
package tests.Concurrency.Condition;
import JACE.ASX.TimeValue;
import java.util.Random;
public class Producer implements Runnable
{
//Maximum pause between enqueues (in milliseconds)
private static final int MAX_PAUSE = 1000;
private SimpleMessageQueue queue_;
private boolean stop_requested_ = false;
private String name_;
private int iterations_;
private TimeValue timeout_;
public Producer(String name,
SimpleMessageQueue queue,
int iterations,
TimeValue timeout)
{
name_ = "Producer " + name;
queue_ = queue;
iterations_ = iterations;
timeout_ = timeout;
}
public void run()
{
//Set the random number generator seed to the current time in milliseconds.
Random random = new Random(System.currentTimeMillis());
int element = 1;
for (int i = 0; i < iterations_; )
{
try
{
// element = random.nextInt();
queue_.enqueue((Object)new Integer(element), timeout_);
System.out.print("Producer::run() " + name_ + " enqueued " + element);
System.out.println(" Queue size: " + queue_.size());
Thread.sleep(random.nextLong() % MAX_PAUSE);
i++;
element++;
}
catch(Exception excp)
{
System.out.print("Producer::run() Exception: ");
System.out.println(excp);
}
}
}
public void requestStop()
{
stop_requested_ = true;
}
}
|
