Java 生产者和消费者问题

运行结果：

code:

class Info {
private String name = "Carter";
private int age = 25;
public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

public int getAge() {
return age;
}

public void setAge(int age) {
this.age = age;
}
}

class Producer implements Runnable {
private Info info = null;
Producer(Info info) {
this.info = info;
}

public void run() {
boolean flag = false;
int i;
for(i=1;i<30;i++) {
if (flag) {
this.info.setName("Carter");
try {
Thread.sleep(100);
} catch(Exception e) {
e.printStackTrace();
}
this.info.setAge(25);
flag = false;
} else {
this.info.setName("Steven");
try {
Thread.sleep(100);
} catch(Exception e) {
e.printStackTrace();
}
this.info.setAge(100);
flag = true;
}
}
}
}

class Consumer implements Runnable {
private Info info = null;
public Consumer(Info info) {
this.info = info;
}

public void run() {
int i;
for(i=1; i<25;i++) {
try {
Thread.sleep(100);
} catch(Exception e) {
e.printStackTrace();
}
System.out.println(this.info.getName() + " <======> " + this.info.getAge());
}
}
}

public class ThreadTest {
public static void main(String[] args) {
Info info = new Info();
Producer pro = new Producer(info);
Consumer con = new Consumer(info);
new Thread(pro).start();
new Thread(con).start();
}
}

等待和唤醒的操作:

code:

class Info {
private String name = "Carter";
private int age = 25;
private boolean flag=false;
public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

public int getAge() {
return age;
}

public void setAge(int age) {
this.age = age;
}

public synchronized void set(String name, int age) {
if (!flag) {
try {
super.wait();
} catch (Exception e) {
e.printStackTrace();
}
}
this.name = name;
try {
Thread.sleep(100);
} catch (Exception e) {
e.printStackTrace();
}
this.age = age;
flag = false;
super.notify();
}
public synchronized void get() {
if (flag) {
try {
super.wait();
} catch (Exception e) {
e.printStackTrace();
}
}
try {
Thread.sleep(100);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(this.getName() + " <===================>" + this.getAge());
flag = true;
super.notify();
}
}

class Producer implements Runnable {
private Info info = null;
Producer(Info info) {
this.info = info;
}

public void run() {
boolean flag = false;
int i;
for(i=1;i<25;i++) {
if (flag) {
this.info.set("Carter", 20);
flag = false;
} else {
this.info.set("Steven",100);
flag = true;
}
}
}
}

class Consumer implements Runnable {
private Info info = null;
public Consumer(Info info) {
this.info = info;
}

public void run() {
int i;
for(i=1; i<25;i++) {
try {
Thread.sleep(100);
} catch(Exception e) {
e.printStackTrace();
}
this.info.get();
}
}
}

Java 生产者和消费者问题相关推荐

java生产者与消费者问题_java生产者与消费者问题
为了回忆一下J2SE中的线程互斥与同步问题,所以今天就写个生产者与消费者问题.这个程序大部分时间的结果都基本正确,但某些时候会造成死锁.百思不得其解,将代码贴上,方便以后有更深的体会时再进行修改.也方 ...
kafka学习总结（含java生产者、消费者、Topic操作代码）
kafka(http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性能和高吞吐率.它的优点是能够直接使用磁盘进行存储.线性读写.速度快,避免了数据在JVM内存和系统内 ...
java多线程生产者消费者_java多线程之-生产者与消费者
java多线程之-并发协作[生产者与消费者]模型对于多线程程序来说,不管c/c++ java python 等任何编程语言,生产者与消费者模型都是最为经典的.也就是可以说多线程的并发协作对于此模型 ...
Java中生产者与消费者问题的演变
想要了解更多关于Java生产者消费者问题的演变吗?那就看看这篇文章吧,我们分别用旧方法和新方法来处理这个问题. 生产者消费者问题是一个典型的多进程同步问题. 对于大多数人来说,这个问题可能是我们在学校 ...
Java多线模式-Producer-Consumer模式（生产者、消费者模式）
1.场景有些时候需要两个或两个以上的线程协同工作,每个线程需要使用其他线程产生数据. 2.详细说明可以把上面的场景抽象成生产者和消费者模式.从消费者的角度:消费者需要消费生产者生成的产品. 从生产 ...
java多线程生产者与消费者问题_Java多线程详解之四:生产者消费者问题
一.问题描述生产者消费者问题(Producer-Consumer problem),也称有限缓冲区问题(Bounded-buffer promblem),是一个多线程同步问题的经典案例.对于一个固定 ...
java的知识点34——线程通信 || 生产者与消费者问题
线程通信应用场景:生产者和消费者问题 • 假设仓库中只能存放一件产品,生产者将生产出来的产品放入仓库,消费者将仓库中产品取走消费 • 如果仓库中没有产品,则生产者将产品放入仓库,否则停止生产并等待, ...
Java多线程-生产者与消费者
Java多线程生产者与消费者,准确说应该是"生产者-消费者-仓储"模型,使用了仓储,使得生产者消费者模型就显得更有说服力. 对于此模型,应该明确一下几点: 1.生产者仅仅在仓储未满 ...
java消费者模式_基于Java 生产者消费者模式(详细分析)
生产者消费者模式是多线程中最为常见的模式:生产者线程(一个或多个)生成面包放进篮子里(集合或数组),同时,消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗.虽然它们任务不同,但处理的资源是相 ...

Java 生产者和消费者问题

Java 生产者和消费者问题相关推荐

最新文章

热门文章