关于多线程的问题

黄玉昆

本帖最后由孙百鑫于 2013-4-21 15:42 编辑

class ProduceConsume
{
public static void main(String[] args)
{
Res r=new Res();
new Thread(new Produce(r)).start();
new Thread(new Consume(r)).start();
new Thread(new Produce(r)).start();
new Thread(new Consume(r)).start();
new Thread(new Produce(r)).start();
new Thread(new Consume(r)).start();
new Thread(new Produce(r)).start();
new Thread(new Consume(r)).start();
new Thread(new Produce(r)).start();
new Thread(new Consume(r)).start();
new Thread(new Produce(r)).start();
new Thread(new Consume(r)).start();
//问题是.开启这么多线程就出问题了.打印结果.求解决因为什么??????????????
/*
Thread-0生产商品..244
Thread-7消费.........商品..244
Thread-6生产商品..245
Thread-1消费.........商品..245
Thread-5消费.........商品..245
Thread-4生产商品..246
Thread-5消费.........商品..246
Thread-1消费.........商品..246
Thread-6生产商品..247
Thread-7消费.........商品..247
Thread-0生产商品..248
Thread-8生产商品..249
Thread-9消费.........商品..249
Thread-3消费.........商品..249
*/
}
}
class Res
{
private String name;
private int count;//计数
private boolean flag;//用于判断if是否该执行
public synchronized void set(String name)//存入线程
{
if(flag)//如果是假等待
try
{
this.wait();
}
catch (Exception e)
{
}
this.name=name+".."+count++;//如果是真.赋值并计数打印
System.out.println(Thread.currentThread().getName()+"生产"+this.name);
flag=true;//然后变成真.并把全部线程唤醒
this.notifyAll();
}
public synchronized void out()//打印线程
{
if(!flag)//如果非假开始等待
try
{
this.wait();
}
catch (Exception e)
{
}
//否则就打印.并且改为假.并把全部线程唤醒
System.out.println(Thread.currentThread().getName()+"消费........."+this.name);
flag=false;
this.notifyAll();
}
}
class Produce implements Runnable//存入线程
{
private Res r;//建立对象引用
Produce(Res r)
{
this.r=r;//初始化对象
}
public void run()
{
while(true)//往里存商品.
{
r.set("商品");
}
}
}
class Consume implements Runnable//打印线程
{
private Res r;//建立对象引用
Consume(Res r)
{
this.r=r;
}
public void run()
{
while(true)//打印商品
r.out();
}
}

复制代码

up.yfei · up.yfei

这个视频上有讲的；
代码完成，加入同步和等待唤醒机制后，可以实现，生产一个，就消费一个。
可是在实际开发中，生产者和消费者，不是一个。有可能是多个
也就是有多个生产者生产,有多个消费者消费。
造成数据错误的原因：当生产者消费者多个时，
本方的线程有可能唤醒本方的线程，而且，本方被唤醒后，没有判断标记，就进行了执行，
会到导致原来本方的操作还没有被对方所操作就已经被覆盖了。
生产者1，进行了生产后，将本方生产者2唤醒，生产者2没有判断标记直接继续生产，
导致生产者1的产品还没有被消费就覆盖了。
解决方式：因为有本方唤醒本方的情况，所以必须每次的醒来都要判断一次标记。
判断标记的动作要执行多次。所以不使用if，而是使用while.

class Resource
{
private String name;
private int count=1;
private boolean flag=false;
public synchronized void set(String name)
{
while(flag) //加上while判断标记
try{this.wait();}catch(Exception e){} //等待
this.name=name+"----"+count++;
System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
flag=true;
this.notifyAll();//唤醒全部
}
public synchronized void out()
{
while(!flag)
try{this.wait();}catch(Exception e){}
System.out.println(Thread.currentThread().getName()+"......消费者......"+this.name);
flag=false;
this.notifyAll();
}
}
class Producer implements Runnable
{
private Resource res;
Producer(Resource res)
{
this.res=res;
}
public void run()
{
while(true)
{
res.set("==商品==");
}
}
}
class Consumer implements Runnable
{
private Resource res;
Consumer(Resource res)
{
this.res=res;
}
public void run()
{
while(true)
{
res.out();
}
}
}
class Demo2
{
public static void main(String[] args)
{
Resource r = new Resource();
Producer pro = new Producer(r);
Consumer con = new Consumer(r);
Thread t1 = new Thread(pro);
Thread t2 = new Thread(pro);
Thread t3 = new Thread(con);
Thread t4 = new Thread(con);
t1.start();
t2.start();
t3.start();
t4.start();
}
}

复制代码

孙百鑫 · 孙百鑫

up.yfei 发表于 2013-4-21 11:13
这个视频上有讲的；
代码完成，加入同步和等待唤醒机制后，可以实现，生产一个，就消费一个。
可是在实际 ...

哦买噶.!!!!!谢谢了.居然犯了这么简单的错误......while....和if写错了.....

帐号		自动登录	找回密码
密码			加入黑马

关于多线程的问题

评分

2 个回复

评分