线程通信Demo

Posted java-jiangtao-home

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了线程通信Demo相关的知识,希望对你有一定的参考价值。

/**
*生产者生成水果,如果水果没有被买走那么就不生产处于等待状态,如果水果被消费者买走的时候,消费者会通知生产者
*告诉生产者,我已经买了,快生产,消费者同理,如果水果已经生产出来就买走,买走之后再通知生产者记得生产
*买的水果是一个对象,是公共的,在synchronize代码块中,
*。
*/

package 等待和唤醒;

public class Fruit {
        private String name;
        
        private boolean isExsit;

        public String getName() {
            return name;
        }

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

        public boolean isExsit() {
            return isExsit;
        }

        public void setExsit(boolean isExsit) {
            this.isExsit = isExsit;
        }

        
        
}
package 等待和唤醒;

public class ProductFruit implements Runnable{
    /**
    *生产者生成水果,如果水果没有被买走那么就不生产处于等待状态,如果水果被消费者买走的时候,消费者会通知生产者
    *告诉生产者,我已经买了,快生产,消费者同理,如果水果已经生产出来就买走,买走之后再通知生产者记得生产
    *买的水果是一个对象,是公共的,在synchronize代码块中,
    *。
     */
    private Fruit fruit;

    public ProductFruit(Fruit fruit) {
        super();
        this.fruit = fruit;
    }

    @Override
    public void run() {

        
            while(true) {
                
                synchronized(fruit) {
                    if(fruit.isExsit()) {
                        try {
                            fruit.wait();
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        
                    }
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println(fruit.getName()+"有水果了");
                    fruit.setExsit(true);
                    fruit.notify();
                    
                }
            }
    }
}
package 等待和唤醒;

public class BuyFruit implements Runnable{
    private Fruit fruit;

    public BuyFruit(Fruit fruit) {
        super();
        this.fruit = fruit;
    }

    @Override
    public void run() {

            while(true) {
                
                synchronized(fruit) {
                    if(!fruit.isExsit()) {
                        try {
                            fruit.wait();
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        
                        
                    }
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println(fruit.getName()+"我来买了!");
                    fruit.setExsit(false);
                    fruit.notify();
                    
                }
            }
        
    }
    
    
}
package 等待和唤醒;

public class Test {
    public static void main(String[] args) {
        Fruit fruit = new Fruit();
        fruit.setExsit(false);
        fruit.setName("苹果");
        ProductFruit pf  = new ProductFruit(fruit);
        Thread t1 = new Thread(pf);
        BuyFruit bf = new BuyFruit(fruit);
        Thread t2 = new Thread(bf);
        t1.start();
        t2.start();
        
        
        
    }
}

 






以上是关于线程通信Demo的主要内容,如果未能解决你的问题,请参考以下文章

多个请求是多线程吗

线程-使用CountDownEvent类

线程-使用SimaphoreSlim类

线程同步-使用ReaderWriterLockSlim类

线程池与并行度

线程池-实现一个取消选项