ProducerConsumer.java

ProducerConsumer.java

package org.xialei.learn.concurrent;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
// 生产者消费者例子
public class Main {
    public static void main(String[] args) {
        List<String> queue = new ArrayList<>();

        Consumer consumer = new Consumer(queue);
        Producer producer = new Producer(queue);

        new Thread(consumer).start();
        new Thread(producer).start();
    }

    // 生产者
    public static class Producer implements Runnable {
        private final List<String> queue;

        Producer(List<String> queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            try {
                while (true) {
                    Thread.sleep(2000);
                    synchronized (queue) {
                        queue.add(new Date().toString());
                        queue.notify();
                    }
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    // 消费者
    public static class Consumer implements Runnable {
        private final List<String> queue;

        Consumer(List<String> queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            while (true) {
                synchronized (queue) {
                    if (queue.size() == 0) {
                        try {
                            queue.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    System.out.println(queue.remove(0));
                }
            }
        }
    }
}