java基础，线程

学到了线程了，但是老师说有一个，生产者和消费者的例子不怎么好理解。希望谁能帮我写一下。。一定要有详细的注释。我好没学到那里，没注释看不懂！！！

江大海 · 江大海

/*
需求：写出一个多线程生产者消费程序
思路，生产者和消费者共同处理一堆资源
生产者和消费者由多个线程处理
*/
class Res
{
private String name;
private boolean kai=false;
private int count=1;
public synchronized void setName(String name)
{
while (kai)//判断生产者里有没有内容，就是有没有生产商品，有生产的话就是true，true的话就要将线程冻结。所以wait，wait也要告诉是哪一个锁wait，同步函数的锁是this。
try{this.wait();}catch(Exception e){}
//当kai是false的时候，就代表里面没有值，就是没有商品，这时需要进行生产，所以执行以下语句
this.name = name+count++;//先进行初始化，把商品的名字和编号进行初始化
System.out.println(Thread.currentThread().getName()+"-----商品已经生产------"+this.name);//为了直观，把初始化的结果打印到控制台
kai = true;//生产完之后吧开关kai变为true，告诉别人，我有值啦，有值啦，所以就不能生产啦，下一步就是要wait，所以就要在冻结前把别人唤醒，因为有可能只唤醒本方，所以要把所有线程唤醒，notifyAll
this.notifyAll();
}
public synchronized void out()
{
while(!kai)//判断开关kai是否有值，假如是false的话就要冻结啦，因为我已经消费过啦，没有商品啦，额，对了，因为wait是有异常的，但是Runnable中没有，所以就要进行try处理
try{this.wait();}catch(Exception e){}
//kai是ture的话就是说我还有值，我还没有被销售，我要被销售，就进行下面的操作
System.out.println(Thread.currentThread().getName()+"----商品已售出---"+this.name);//把销售的结果打印出控制台
kai = false;//告诉别人我别销售完毕啦，把kai置为false，下一步就是要冻结啦，就要把所有线程唤醒，
this.notifyAll();
}
}
class Producer implements Runnable
{
private Res r;
Producer(Res r)//将资源传递给生产者，并进行赋值打印处理
{
this.r = r;
}
public void run()
{
while (true)//因为要打印多次，并且不知道打印次数，所以用while
{
r.setName("商品");
}
}
}
class Consumer implements Runnable
{
private Res r;
Consumer(Res r)//把资源传递给消费者，并进行输出处理
{
this.r = r;
}
public void run()
{
while (true)
{
r.out();
}
}
}
class h
{
public static void main(String[] args)
{
Res r = new Res();
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();
}
}

复制代码

这个是第二步的

江大海 · 江大海

/*
需求：写出一个多线程生产者消费程序
思路，生产者和消费者共同处理一堆资源
生产者和消费者由多个线程处理
*/
class Res
{
private String name;
private boolean kai=false;
private int count=1;
public synchronized void setName(String name)
{
while (kai)
try{this.wait();}catch(Exception e){}
this.name = name+count++;//先进行初始化，把商品的名字和编号进行初始化
System.out.println(Thread.currentThread().getName()+"-----商品已经生产------"+this.name);//为了直观，把初始化的结果打印到控制台
kai = true;
this.notifyAll();
}
public synchronized void out()
{
while(!kai)
try{this.wait();}catch(Exception e){}
System.out.println(Thread.currentThread().getName()+"----商品已售出---"+this.name);//把销售的结果打印出控制台
kai = false;
this.notifyAll();
}
}
class Producer implements Runnable
{
private Res r;
Producer(Res r)//将资源传递给生产者，并进行赋值打印处理
{
this.r = r;
}
public void run()
{
while (true)//因为要打印多次，并且不知道打印次数，所以用while
{
r.setName("商品");
}
}
}
class Consumer implements Runnable
{
private Res r;
Consumer(Res r)//把资源传递给消费者，并进行输出处理
{
this.r = r;
}
public void run()
{
while (true)
{
r.out();
}
}
}
class h
{
public static void main(String[] args)
{
Res r = new Res();
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();
}
}

复制代码

无语，那个没复制到，这是第一步的

江大海 · 江大海

哎哟喂，道友真是有源啦，我也刚学到这里，我觉得要理解这个程序的话可以分为两步，
第一步是先要把代码的基本功能看懂，把基本的功能看懂了就成功了一大把办
第二步才是要看多线程同步的，代码我分开来说，先是程序的基本功能

this.notifyAll();

复制代码

这个是第一步的，下面是才是关于多线程同步的

石贤芝 · 石贤芝

先说两点基本的概念：
1，关于进程与线程。
所谓进程，就是指电脑中一个正在运行中的程序，也指这个运行的程序在内存中开辟的一块内存空间。比如当我们用QQ上网聊天时，QQ这个程序（或者说为QQ程序开辟的那块内存空间）就是一个进程。
所谓线程，是指负责程序执行的一个控制单元，也称之为执行路径。
一个进程中至少有一条执行路径，也可以有多条执行路径。
当进程中有多条执行路径时，我们就称之为多线程。
在一个 java 程序的运行中，多线程就是指，除了运行 main 函数的那个线程(主线程) 之外，还有其他的线程和主线程并发执行。

2，开启一个新线程的两种方式。
第一种方式：新建一个子类，继承Tread类，复写Tread类的 run() 方法，实例化这个子类，调用start() 方法。
第二种方式：新建一个子类，实现Runnable接口，复写run() 方法，实例化这个类，把这个子类对象作为参数传递给new Thread（“子类对象”）。调用start()方法。
由于在java中，子类只有一个父类，这样子类如果继承了Tread类，就不能再继承其他的类了；这就导致创建线程的第一种方式有固有的局限性；一般情况下，创建一个线程用第二种方式即可。

下面是代码演示：

//共享的资源类
class Resource {
private String name;
private int count = 1;
// 当flag标记为真(有货)时，执行负责消费的同步代码块，当flag标记为假(无货)时，执行负责生产的同步代码块
private boolean flag = false;
//负责生产的同步代码块
public synchronized void set(String name) {
while (flag)
try {
this.wait(); // 先判断flag，如果不满足，此线程要进入等待状态；若满足继续向下执行
} catch (InterruptedException e) {
}
this.name = name + count;
count++;
System.out.println(Thread.currentThread().getName() + "....生产者..."
+ this.name);
flag = true; // 生产完之后，就有存货了，flag修改为真
notify(); // 唤醒其它的线程
}
//负责消费的同步代码块
public synchronized void out() {
while (!flag)
try {
this.wait(); // 先判断flag，如果不满足，此线程要进入等待状态；若满足继续向下执行
} catch (InterruptedException e) {
}
System.out.println(Thread.currentThread().getName()
+ "....消费者............." + this.name);
flag = false; // 消费完之后，就没有存货了，flag修改为假
notify(); // 唤醒其它的线程
}
}
//生产者类，实现Runnable接口，覆盖run()方法
class Producer implements Runnable {
private Resource r;
Producer(Resource r) {
this.r = r;
}
public void run() {
while (true) {
r.set("烤羊肉串");
}
}
}
//消费者类，实现Runnable接口，覆盖run()方法
class Consumer implements Runnable {
private Resource r;
Consumer(Resource r) {
this.r = r;
}
public void run() {
while (true) {
r.out();
}
}
}
//演示类
class MyProducerConsumer {
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(con);
t1.start();
t2.start();
}
}

复制代码

先注释这么多，有问题可以讨论，或者自己看一下视频。。

韩秀山 · 韩秀山

chouwayメ发表于 2013-5-15 18:15
这是老师的源码。标注么，其实老师的视频就是最好的标注了。

谢谢！！！

chouwayメ · chouwayメ

这是老师的源码。标注么，其实老师的视频就是最好的标注了。

class ProducerConsumerDemo
{
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();
}
}
/*
对于多个生产者和消费者。
为什么要定义while判断标记。
原因：让被唤醒的线程再一次判断标记。
为什么定义notifyAll，
因为需要唤醒对方线程。
因为只用notify，容易出现只唤醒本方线程的情况。导致程序中的所有线程都等待。
*/
class Resource
{
private String name;
private int count = 1;
private boolean flag = false;
// t1 t2
public synchronized void set(String name)
{
while(flag)
try{this.wait();}catch(Exception e){}//t1(放弃资格) t2(获取资格)
this.name = name+"--"+count++;
System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
flag = true;
this.notifyAll();
}
// t3 t4
public synchronized void out()
{
while(!flag)
try{wait();}catch(Exception e){}//t3(放弃资格) t4(放弃资格)
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();
}
}
}

复制代码

韩秀山 · 韩秀山

兴朗ok 发表于 2013-5-15 18:05
多生产多消费图解（老毕）

:'( 只是图解吗？看不懂啊！有源码吗？

兴朗ok · 兴朗ok

本帖最后由兴朗ok 于 2013-5-15 18:08 编辑

多生产多消费图解（老毕）

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

java基础，线程

8 个回复

评分

评分

评分