46
我想创建某种Producer/Consumer线程应用程序。但我不确定在两者之间实现队列的最佳方式。使用队列的生产者/消费者线程
所以我有两个想法（这可能是完全错误的）。我想知道哪个更好，如果他们都吸了，那么实施队列的最好方法是什么。这主要是我在这些例子中执行的队列，我很关心。我正在扩展一个Queue类，它是一个内部类，并且是线程安全的。下面是两个例子，每个例子有4个类。
主要类 -
public class SomeApp
{
private Consumer consumer;
private Producer producer;
public static void main (String args[])
{
consumer = new Consumer();
producer = new Producer();
}
}
消费者接收机类
public class Consumer implements Runnable
{
public Consumer()
{
Thread consumer = new Thread(this);
consumer.start();
}
public void run()
{
while(true)
{
//get an object off the queue
Object object = QueueHandler.dequeue();
//do some stuff with the object
}
}
}
生产者接收机类
public class Producer implements Runnable
{
public Producer()
{
Thread producer = new Thread(this);
producer.start();
}
public void run()
{
while(true)
{
//add to the queue some sort of unique object
QueueHandler.enqueue(new Object());
}
}
}
队列接收机类
public class QueueHandler
{
//This Queue class is a thread safe (written in house) class
public static Queue<Object> readQ = new Queue<Object>(100);
public static void enqueue(Object object)
{
//do some stuff
readQ.add(object);
}
public static Object dequeue()
{
//do some stuff
return readQ.get();
}
}
OR
主要类 -
public class SomeApp
{
Queue<Object> readQ;
private Consumer consumer;
private Producer producer;
public static void main (String args[])
{
readQ = new Queue<Object>(100);
consumer = new Consumer(readQ);
producer = new Producer(readQ);
}
}
消费者接收机类
public class Consumer implements Runnable
{
Queue<Object> queue;
public Consumer(Queue<Object> readQ)
{
queue = readQ;
Thread consumer = new Thread(this);
consumer.start();
}
public void run()
{
while(true)
{
//get an object off the queue
Object object = queue.dequeue();
//do some stuff with the object
}
}
}
生产者接收机类
public class Producer implements Runnable
{
Queue<Object> queue;
public Producer(Queue<Object> readQ)
{
queue = readQ;
Thread producer = new Thread(this);
producer.start();
}
public void run()
{
while(true)
{
//add to the queue some sort of unique object
queue.enqueue(new Object());
}
}
}
队列接收机类
//the extended Queue class is a thread safe (written in house) class
public class QueueHandler extends Queue<Object>
{
public QueueHandler(int size)
{
super(size); //All I'm thinking about now is McDonalds.
}
public void enqueue(Object object)
{
//do some stuff
readQ.add();
}
public Object dequeue()
{
//do some stuff
return readQ.get();
}
}
去吧！
生产者enqueue和消费者出队，顺便说一句。反之亦然.. – 2010-02-25 08:22:25
哦，不要从构造函数中启动线程！该线程可以观察处于不一致状态的对象。有关详细信息，请参阅“Java并发实践”。 – 2010-02-25 08:24:12
谢谢Zwei，入队的事情是我没有专注。从构造函数的东西开始线程我应该运行一个intiliazation方法，并在那里启动它，或者它应该从主方法类启动它？ – Gareth 2010-02-25 09:05:29