生产者消费者模式

2010-12-12 489 0

用两种方式实现

第一种,使用timertask实现,timertask,可以比较精确的实现定时任务。

在这里插一句,java的实时性是很差的,timertask也就是大概的可以实现

看代码:

Producer.java


package me.dapeng.timer;
import java.util.concurrent.LinkedBlockingQueue;
public class Producer extends Thread {
private LinkedBlockingQueue queue;
public Producer(LinkedBlockingQueue queue) {
this.queue = queue;
}
@Override
public void run() {
int i = 0;
while (true) {
queue.offer("string" + i);
// System.err.println("[Producer]queue size:" + queue.size());
i++;
}
}
}


Consumer.java


package me.dapeng.timer;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.TimerTask;
import java.util.concurrent.LinkedBlockingQueue;
public class Consumer extends TimerTask {
private LinkedBlockingQueue queue;
public Consumer(LinkedBlockingQueue queue) {
this.queue = queue;
}
@Override
public void run() {
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String date = formatter.format(new Date());
int size = queue.size();
try {
if (size > 0) {
String str = (String) queue.poll();
System.err.println(date + "-" + str);
} else {
Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}


TestPoll.java


package me.dapeng.timer;
import java.util.Timer;
import java.util.concurrent.LinkedBlockingQueue;
public class TestPoll {
private final static LinkedBlockingQueue queue = new LinkedBlockingQueue(1000);
public static void main(String[] args) {
Producer producer = new Producer(queue);
producer.start();
Consumer consumer = new Consumer(queue);
Timer timer = new Timer();
timer.schedule(consumer, 2000, 1000);
}
}


第二种方式

Producer.java


package me.dapeng.poll;
import java.util.concurrent.LinkedBlockingQueue;
public class Producer extends Thread {
private LinkedBlockingQueue queue;
public Producer(LinkedBlockingQueue queue) {
this.queue = queue;
}
@Override
public void run() {
int i = 0;
while (true) {
queue.offer("string" + i);
// System.err.println("[Producer]queue size:" + queue.size());
i++;
}
}
}


Consumer.java


package me.dapeng.poll;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
public class Consumer extends Thread {
private LinkedBlockingQueue queue;
public Consumer(LinkedBlockingQueue queue) {
this.queue = queue;
}
@Override
public void run() {
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
int i = 0;
while (true) {
String date = formatter.format(new Date());
int size = queue.size();
try {
if (size > 0) {
String str = (String) queue.poll(1, TimeUnit.SECONDS);
System.err.println(str);
} else {
Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
i++;
}
}
}


TestPoll.java


package me.dapeng.poll;
import java.util.concurrent.LinkedBlockingQueue;
public class TestPoll {
private final static LinkedBlockingQueue queue = new LinkedBlockingQueue(1000);
public static void main(String[] args) {
Producer producer = new Producer(queue);
producer.start();
Consumer consumer = new Consumer(queue);
consumer.start();
}
}


_

其实这两种方式,都是同样的代码,仅仅是换用了timertask和while(true),重点还是用了queue,只是为了和我们老大证明queue.pool的使用方式而已。

_

相关文章

15年来的手艺之路:手艺人赵鹏的自述
纪念 Google 25 周年:从搜索引擎到科技巨头的演变之路
1小时编写一个支持七牛上传的 markdown 客户端3(打包发布篇)
1小时编写一个支持七牛上传的 markdown 客户端2(代码优化篇)
1小时编写一个支持七牛上传的 markdown 客户端1(技术实现篇)
从 wordpress 转移到 hexo

Leave a Reply