Java 利用队列和多线程的思想完成用户排队买票。

﹏ヽ暗。殇╰゛Y 2022-03-27 06:56 332阅读 0赞

要求:可以通过ArrayList或LinkedList接口完成队列的创建，可以实现入队、出队等操作。新定义类利用多线程的思想完成买票和卖票的同步操作。

代码：

import java.util.ArrayList;
    import java.util.EmptyStackException;
    import java.util.LinkedList;
    import java.util.List;
    
    class Goods {
        private String goodsName;//商品名称
        MyQueue q = new MyQueue();
        public synchronized void setGoods(String goodsName) {//生产商品方法
            //当前还有商品需要等待消费者消费后才生产
            while (q.size() > 0){
                try {
                    System.out.println("正在售票。。。");
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            this.goodsName = goodsName;
            q.add("票");
            System.out.println(Thread.currentThread().getName()+"生产" + toString());
            //生产完后唤醒
            notifyAll();
        }
    
        public synchronized void getGoods() {//消费商品方法
            while (q.size() == 0){
                try {
                    System.out.println("卖完了。");
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            q.remove();
            System.out.println(Thread.currentThread().getName()+"消费" + toString());
            //消费完后，告诉生产者生产
            notifyAll();
        }
    
        @Override
        public String toString() {
            return "Goods{" + "goodsName='" + goodsName + '\'' + ", count=" + q.size() + '}';
        }
    }
    
    //生产者
    class Producer implements Runnable {
        private Goods goods;
    
        public Producer(Goods goods) {
            this.goods = goods;
        }
    
        public void run() {
            while (true) {
                this.goods.setGoods("生产票");
            }
        }
    }
    
    //消费者
    class Consumer implements Runnable {
        private Goods goods;
    
        public Consumer(Goods goods) {
            this.goods = goods;
        }
    
        public void run() {
            while (true) {
                this.goods.getGoods();
            }
        }
    }
    
    class MyQueue {
        private LinkedList<Object> link = new LinkedList<Object>();
    
        public MyQueue() {
    
        }
    
        public void add(Object obj) {//添加元素
            link.addLast(obj);
        }
    
        public Object remove() {//删除元素
            if (isEmpty()) {
                throw new EmptyStackException();
            }
            return link.removeFirst();
        }
        public int size(){//求长度
            return link.size();
        }
        public boolean isEmpty() {//判断是不是空
            return link.isEmpty();
        }
        public void clear() {//清空
            link.clear();
        }
    }
    
    public class Queue {
        public static void main(String[] args) {
            Goods goods = new Goods();
            //存储生产消费者线程
            List<Thread> list = new ArrayList<>();
            Producer producer = new Producer(goods);
            Consumer consumer = new Consumer(goods);
            for(int i= 0;i<5;i++){
                Thread thread = new Thread(producer,"生产者"+i);
                list.add(thread);
            }
            for (int i = 0;i<10;i++){
                Thread thread = new Thread(consumer,"消费者"+i);
                list.add(thread);
            }
            for (Thread thread:list) {
                thread.start();
            }
        }
    }