zoukankan      html  css  js  c++  java
  • 简单生产消费模型

    import java.util.Queue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.LinkedBlockingQueue;
    
    public class Application {
        final static int TASKCOUNT = 20;
    
        public static void main(String args[]) {
            CountDownLatch locked = new CountDownLatch(TASKCOUNT);
            Queue<Integer> queue = new LinkedBlockingQueue<>(TASKCOUNT);
            Producer producer = new Producer(locked, queue, TASKCOUNT);
            Consumer comsumer = new Consumer(locked, queue);
            new Thread(producer).start();
            new Thread(comsumer).start();
            new Thread(comsumer).start();
            System.out.println("主线程结束");
        }
    }
    
    class Producer implements Runnable {
    
        CountDownLatch locked;
        Queue<Integer> queue;
        int count;
    
        public Producer(CountDownLatch locked, Queue<Integer> queue, int count) {
            this.locked = locked;
            this.queue = queue;
            this.count = count;
        }
    
        @Override
        public void run() {
            for (int i = 0; i < 20; i++) {
                this.queue.add(i);
                this.locked.countDown();
            }
            System.out.println(String.format("生产线程 %s 结束",Thread.currentThread().getId()));
        }
    }
    
    class Consumer implements Runnable {
    
        CountDownLatch locked;
        Queue<Integer> queue;
    
        public Consumer(CountDownLatch locked, Queue<Integer> queue) {
            this.locked = locked;
            this.queue = queue;
        }
    
        @Override
        public void run() {
            try {
                this.locked.await();
                while (true) {
                    if (this.queue.isEmpty()) {
                        break;
                    }
                    System.out.println(String.format("消费线程 ThreadId = %s, Task = %s ", Thread.currentThread().getId(), this.queue.poll()));
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                System.out.println(String.format("消费线程 %s 结束",Thread.currentThread().getId()));
            }
        }
    }
  • 相关阅读:
    夜神 虚拟机调试 HBuilder 移动端应用
    maven filter 文件分环境打包部署小问题
    fatal: remote error: CAPTCHA required
    程序员今年是这样计划的
    线程池shutdown与shutdownnow 小例子
    JAVA知识点脉络记忆-刻意练习
    日志
    (职员)2015-12-02 星期三 日志
    (职员)2015-12-04 星期五 周志
    (职员)2015-12-04 星期五 日志
  • 原文地址:https://www.cnblogs.com/fqybzhangji/p/11934140.html
Copyright © 2011-2022 走看看