java的生产者消费者

1. java线程生产者消费者问题

你的消费者线程先启动的，因为index==0，所以进入了等待模式，而生产者线程没有在push了之后进行唤醒，导致了问题。
测试在push方法中的index++后面添加notifyAll()方法可以解决该问题：
index++;
this.notifyAll();
Thread-1生产了1号馒头
Thread-0消费了第1个馒头
Thread-1生产了2号馒头
Thread-0消费了第2个馒头
Thread-1生产了3号馒头
Thread-0消费了第3个馒头
Thread-1生产了4号馒头
Thread-0消费了第4个馒头
Thread-1生产了5号馒头
Thread-0消费了第5个馒头
Thread-1生产了6号馒头
Thread-0消费了第6个馒头
Thread-1生产了7号馒头
Thread-0消费了第7个馒头
Thread-1生产了8号馒头
Thread-0消费了第8个馒头
Thread-1生产了9号馒头
Thread-0消费了第9个馒头

2. java 生产者消费者是设计模式吗

对于多线程程序来说，不管任何编程语言，生产者和消费者模型都是最经典的。就像学习每一门编程语言一 样，Hello World!都是最经典的例子。
实际上，准确说应该是“生产者-消费者-仓储”模型，离开了仓储，生产者消费者模型就显得没有说服力了。
对于此模型，应该明确一下几点：
1、生产者仅仅在仓储未满时候生产，仓满则停止生产。
2、消费者仅仅在仓储有产品时候才能消费，仓空则等待。
3、当消费者发现仓储没产品可消费时候会通知生产者生产。
4、生产者在生产出可消费产品时候，应该通知等待的消费者去消费。
此模型将要结合java.lang.Object的wait与notify、notifyAll方法来实现以上的需求。这是非常重要的。

3. JAVA模拟生产者与消费者实例

使用的生产者和消费者模型具有如下特点：
(1)本实验的多个缓冲区不是环形循环的，也不要求按顺序访问。生产者可以把产品放到目前某一个空缓冲区中。
(2)消费者只消费指定生产者的产品。
(3)在测试用例文件中指定了所有的生产和消费的需求，只有当共享缓冲区的数据满足了所有关于它的消费需求后，此共享缓冲区才可以作为空闲空间允许新的生产者使用。
(4)本实验在为生产者分配缓冲区时各生产者间必须互斥，此后各个生产者的具体生产活动可以并发。而消费者之间只有在对同一产品进行消费时才需要互斥，同时它们在消费过程结束时需要判断该消费对象是否已经消费完毕并清除该产品。
Windows
用来实现同步和互斥的实体。在Windows
中，常见的同步对象有：信号量(Semaphore)、
互斥量(Mutex)、临界段(CriticalSection)和事件(Event)等。本程序中用到了前三个。使用这些对象都分
为三个步骤，一是创建或者初始化：接着请求该同步对象，随即进入临界区，这一步对应于互斥量的
上锁；最后释放该同步对象，这对应于互斥量的解锁。这些同步对象在一个线程中创建，在其他线程
中都可以使用，从而实现同步互斥。当然，在进程间使用这些同步对象实现同步的方法是类似的。
1．用锁操作原语实现互斥
为解决进程互斥进人临界区的问题，可为每类临界区设置一把锁，该锁有打开和关闭两种状态，进程执行临界区程序的操作按下列步骤进行：
①关锁。先检查锁的状态，如为关闭状态，则等待其打开；如已打开了，则将其关闭，继续执行步骤②的操作。
②执行临界区程序。
③开锁。将锁打开，退出临界区。
2．信号量及WAIT，SIGNAL操作原语
信号量的初值可以由系统根据资源情况和使用需要来确定。在初始条件下信号量的指针项可以置为0，表示队列为空。信号量在使用过程中它的值是可变的，但只能由WAIT，SIGNAL操作来改变。设信号量为S，对S的WAIT操作记为WAIT（S），对它的SIGNAL操作记为SIGNAL（S）。
WAIT（S）：顺序执行以下两个动作：
①信号量的值减1，即S=S－1；
②如果S≥0，则该进程继续执行；
如果
S（0，则把该进程的状态置为阻塞态，把相应的WAITCB连人该信号量队列的末尾，并放弃处理机，进行等待（直至其它进程在S上执行SIGNAL操作，把它释放出来为止）。
SIGNAL（S）：顺序执行以下两个动作
①S值加
1，即
S=S＋1；
②如果S）0，则该进程继续运行；
如果S（0则释放信号量队列上的第一个PCB（既信号量指针项所指向的PCB）所对应的进程（把阻塞态改为就绪态），执行SIGNAL操作的进程继续运行。
在具体实现时注意，WAIT，SIGNAL操作都应作为一个整体实施，不允许分割或相互穿插执行。也就是说，WAIT，SIGNAL操作各自都好像对应一条指令，需要不间断地做下去，否则会造成混乱。
从物理概念上讲，信号量S）时，S值表示可用资源的数量。执行一次WAIT操作意味着请求分配一个单位资源，因此S值减1；当S<0时，表示已无可用资源，请求者必须等待别的进程释放了该类资源，它才能运行下去。所以它要排队。而执行一次SIGNAL操作意味着释放一个单位资源，因此S值加1；若S（0时，表示有某些进程正在等待该资源，因而要把队列头上的进程唤醒，释放资源的进程总是可以运行下去的。
---------------
/**
*
生产者
*
*/
public
class
Procer
implements
Runnable{
private
Semaphore
mutex,full,empty;
private
Buffer
buf;
String
name;
public
Procer(String
name,Semaphore
mutex,Semaphore
full,Semaphore
empty,Buffer
buf){
this.mutex
=
mutex;
this.full
=
full;
this.empty
=
empty;
this.buf
=
buf;
this.name
=
name;
}
public
void
run(){
while(true){
empty.p();
mutex.p();
System.out.println(name+"
inserts
a
new
proct
into
"+buf.nextEmptyIndex);
buf.nextEmptyIndex
=
(buf.nextEmptyIndex+1)%buf.size;
mutex.v();
full.v();
try
{
Thread.sleep(1000);
}
catch
(InterruptedException
e)
{
e.printStackTrace();
}
}
}
}
---------------
/**
*
消费者
*
*/
public
class
Customer
implements
Runnable{
private
Semaphore
mutex,full,empty;
private
Buffer
buf;
String
name;
public
Customer(String
name,Semaphore
mutex,Semaphore
full,Semaphore
empty,Buffer
buf){
this.mutex
=
mutex;
this.full
=
full;
this.empty
=
empty;
this.buf
=
buf;
this.name
=
name;
}
public
void
run(){
while(true){
full.p();
mutex.p();
System.out.println(name+"
gets
a
proct
from
"+buf.nextFullIndex);
buf.nextFullIndex
=
(buf.nextFullIndex+1)%buf.size;
mutex.v();
empty.v();
try
{
Thread.sleep(1000);
}
catch
(InterruptedException
e)
{
e.printStackTrace();
}
}
}
}
-------------------------
/**
*
缓冲区
*
*/
public
class
Buffer{
public
Buffer(int
size,int
nextEmpty,int
nextFull){
this.nextEmptyIndex
=
nextEmpty;
this.nextFullIndex
=
nextFull;
this.size
=
size;
}
public
int
size;
public
int
nextEmptyIndex;
public
int
nextFullIndex;
}
-----------------
/**
*
此类用来模拟信号量
*
*/
public
class
Semaphore{
private
int
semValue;
public
Semaphore(int
semValue){
this.semValue
=
semValue;
}
public
synchronized
void
p(){
semValue--;
if(semValue<0){
try
{
this.wait();
}
catch
(InterruptedException
e)
{
e.printStackTrace();
}
}
}
public
synchronized
void
v(){
semValue++;
if(semValue<=0){
this.notify();
}
}
}
------------------------
public
class
Test
extends
Thread
{
public
static
void
main(String[]
args)
{
Buffer
bf=new
Buffer(10,0,0);
Semaphore
mutex=new
Semaphore(1);
Semaphore
full=new
Semaphore(0);
Semaphore
empty=new
Semaphore(10);
//new
Thread(new
Procer("p001",mutex,full,empty,bf)).start();
Procer
p=new
Procer("p001",mutex,full,empty,bf);
new
Thread(new
Procer("p002",mutex,full,empty,bf)).start();
new
Thread(new
Procer("p003",mutex,full,empty,bf)).start();
new
Thread(new
Procer("p004",mutex,full,empty,bf)).start();
new
Thread(new
Procer("p005",mutex,full,empty,bf)).start();
try{
sleep(3000);
}
catch(Exception
ex)
{
ex.printStackTrace();
}
new
Thread(new
Customer("c001",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c002",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c003",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c004",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c005",mutex,full,empty,bf)).start();
}
}
--------------------------------------------

4. JAVA生产者，消费者问题

确实在生产者和消费者之间进行了同步，但是在各自线程的run（）方法中打印的内容和put，get操作无关所以无法保持同步，导致了输出结果混乱，另外消费者线程的run方法也要作适当修改，这里让他在接受到最后一个字符‘e’后暂停一秒终止，代码如下：
class app15
{
private char ch;
public volatile boolean available = false;

synchronized char get()
{
while (available == false)
{
try
{
wait();
}
catch (InterruptedException e)
{
}
}
available = false;
notify();
System.out.println("接受到的数据是: "+ch);
return ch;
}

synchronized void put(char newch)
{
while (available == true)
{
try
{
wait();
}
catch (InterruptedException e)
{
}
}
ch = newch;
available = true;
System.out.println("生产的数据是：" + ch);
notify();
}

public static void main(String args[])
{
app15 comn = new app15();
procer p = new procer(comn);
consumer c = new consumer(comn);
p.start();
c.start();
}
}

class procer extends Thread
{
private app15 comn;

public procer(app15 thiscomn)
{
comn = thiscomn;
}

public void run()
{
char c;
for (c = 'a'; c <= 'e'; c++)
{

comn.put(c);

}
}
}

class consumer extends Thread
{
private app15 comn;

public consumer(app15 thiscomn)
{
comn = thiscomn;
}

public void run()
{
while(true)
{
if(comn.get()=='e')
{
try
{
Thread.sleep(1000);
}
catch(InterruptedException e)
{
Thread.currentThread().interrupt();
}
break;
}

}
}
}

5. java 生产者 消费者问题

这个很好解释。
生产0消费0后，生产者生产了1后，
b.pull(sb);//这一块执行完，cup的时间被消费者，消费消费后打印出消费了1。然后生产者线程才又抢到执行时间。执行这一句。
System.out.println( 生产了+ sb);
为什么会这样，因为你两个线程的run方法没有互斥。
你如果将打印语句放在SteamedBun sb = b.pop();
pop（）方法内部执行就行了。

6. java 怎样测试生产者消费者

这个主要涉及到线程相关的东西。一个类用于生产（Proct），一个类用于卖出（Customer），再加一个用于存储的类(Data)。理清他们之间的逻辑。生产以及卖出的时候最好用一个标示来表明Data中的数量是否允许继续生产或者卖出。

7. java实现生产者和消费者问题的几种方式

生产者消费者问题是多线程的一个经典问题，它描述是有一块缓冲区作为仓库，生产者可以将产品放入仓库，消费者则可以从仓库中取走产品。
解决生产者/消费者问题的方法可分为两类：
采用某种机制保护生产者和消费者之间的同步；
在生产者和消费者之间建立一个管道。
第一种方式有较高的效率，并且易于实现，代码的可控制性较好，属于常用的模式。第二种管道缓冲区不易控制，被传输数据对象不易于封装等，实用性不强。
在Java中有四种方法支持同步，其中前三个是同步方法，一个是管道方法。
wait()
/
notify()方法
await()
/
signal()方法
BlockingQueue阻塞队列方法
PipedInputStream
/
PipedOutputStream
通过
wait()
/
notify()方法实现：
wait()
/
nofity()方法是基类Object的两个方法：
wait()方法：当缓冲区已满/空时，生产者/消费者线程停止自己的执行，放弃锁，使自己处于等等状态，让其他线程执行。
notify()方法：当生产者/消费者向缓冲区放入/取出一个产品时，向其他等待的线程发出可执行的通知，同时放弃锁，使自己处于等待状态。
通过await()
/
signal()方法实现：
await()和signal()的功能基本上和wait()
/
nofity()相同，完全可以取代它们，但是它们和新引入的锁定机制Lock直接挂钩，具有更大的灵活性。通过在Lock对象上调用newCondition()方法，将条件变量和一个锁对象进行绑定，进而控制并发程序访问竞争资源的安全。
通过BlockingQueue方法实现：
它是一个已经在内部实现了同步的队列，实现方式采用的是我们第2种await()
/
signal()方法。它可以在生成对象时指定容量大小。它用于阻塞操作的是put()和take()方法：
put()方法：类似于我们上面的生产者线程，容量达到最大时，自动阻塞。
take()方法：类似于我们上面的消费者线程，容量为0时，自动阻塞。

8. java 生产者与消费者 的简单问题

1 toString是在控制台打印对象的时候会调用的对象的方法。。比如你定义个Sx对象sx。。然后System.out.println(sx);就会先调用sx的toString方法。。将得到的String对象打印在控制台。。每个类都继承自Object。。Object类里面有个toString方法。。返回的是该对象在内存中的地址。。如果你不重写这个方法。。打印出来的东西你看不明白的。。
2 java中数据类型有基本类型（int那些）和引用类型（就是所谓的对象）。。java中数组是对象。。每个数组对象都有一个length属性。。值是这个数组的元素个数。。对象调用属性是不需要括号的。。方法才需要。。
3 kuang ss=null;就是定义一个kuang对象ss。。其初始值为null。。为null的对象在内存中什么都没有
int index=0; Wotou[] tou=new Wotou[6];这两个都不是为空的。。都有具体的初始值。。
4 Wotou wt=ss.pop();表示定义一个Wotou对象wt。。并将调用ss对象的pop方法的返回值赋值给wt对象。。具体你看下kuang 类的pop方法就知道了。。

9. java中生产者消费者的问题

食人花其实是大花草。因为花的直径很大又加上花体本身会散发出一种腐烂的尸臭味。所以让人以为他会吃人。才会有食人花这个名字的由来。其实食人花差不多值得是食虫植物（食肉植物）。食肉植物能将捕获的动物分解，这个过程类似动物的消化过程。分解的最终产物，尤其是氮的化合物及盐类为植物所吸收。食肉植物多数能进行光合作用，又能消化动物蛋白质，能适应极端的环境。因此它既是生产者也是消费者。

手机看岛国电影 进酷影模式,看片没广告,啥资源都有

10. java多生产者和多消费者

public static void main(String[] args) {
Buffer buffer=new Buffer(); //创建一个临界区对象
new Procer(buffer,100).start(); //创建一个生产者对象，并启动其线程
new Consumer(buffer,200).start(); //创建一个消费者对象，并启动其线程
new Consumer(buffer,201).start(); //创建第二个消费者对象，并启动其线程
}

这一段代码，多加入
new Consumer(buffer,201).start(); //创建第二个消费者对象，并启动其线程
多加一段代码创建一个消费者
多加入
new Procer(buffer,100).start();
创建一个生产者。
想要很多生产者和消费者？加就是了啊。

第四个文件 Buffer.java
这个是实现同步的主要缓存类。想要实现同步
在每个方法的声明前都加入synchronized 就行
synchronized 线程锁，很好用的。源代码已经加入了
就比如
public synchronized void put(int value) { //同步方法控制临界区内容写入