黑马程序员技术交流社区

标题: 学习 [打印本页]

---

作者: 徐本发    时间: 2018-12-27 14:44
标题: 学习
//1.定义一个Fruit水果类
//                成员变量：stock库存
//                构造方法、set和get
public class Fruit {
    private int stock;
    boolean flag=true;
    public Fruit() {
    }
    public Fruit(Integer stock) {
        this.stock = stock;
    }
    public Integer getStock() {
        return stock;
    }
    public void setStock(Integer stock) {
        this.stock = stock;
    }
    @Override
    public String toString() {
        return "Fruit{" +
                "stock=" + stock +
                '}';
    }
}



//定义一个官网线程类：NetShop，实现Runnable接口
//                完成卖出水果的动作
public class NetShop implements Runnable {
   private Fruit jg;
    public  NetShop(Fruit jg){
        this.jg=jg;
    }
    @Override
    public void run() {
        while (true) {
            synchronized (jg) {
                if (jg.flag == true) {
                    try {
                        jg.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
        Integer stock = jg.getStock();
                    if (stock > 0) {
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        jg.setStock(--stock);
                        System.out.println(Thread.currentThread().getName() + "正在卖出第" + (100 - stock) + "份，还剩余" + stock + "份");
                        jg.flag = true;

                    }
                    jg.notify();

                    if (jg.getStock() <= 0) {
                        break;
                    }

                }


            }
        }

    }



//3.定义一个实体店线程类：FrontShop，实现Runnable接口
//                完成卖出水果的动作
public class FrontShop implements Runnable{

    private Fruit jg;
    public  FrontShop(Fruit jg){
        this.jg=jg;
    }
    @Override
    public void run() {

        while (true){
            synchronized (jg){
                if (jg.flag==false) {

                    try {
                        jg.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                Integer stock = jg.getStock();

                if(stock>0){
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    jg.setStock(--stock);
                    System.out.println(Thread.currentThread().getName()+"正在卖出第"+(100-stock)+"份，还剩余"+stock+"份");
                    jg.flag=false;

                }
                jg.notify();

                if (jg.getStock()<=0){
                    break;
                }
            }
        }
    }
}




import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Text {
    public static void main(String[] args) {
        Fruit fruit = new Fruit(100);

        NetShop netShop = new NetShop(fruit);
        FrontShop frontShop = new FrontShop(fruit);

        Thread thread = new Thread(netShop, "网店");
        Thread thread1 = new Thread(frontShop, "实体");
        ExecutorService service= Executors.newFixedThreadPool(2);


        thread.start();
        thread1.start();

        service.shutdown();

    }
}

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2