小知识:linkedList.poll()方法:在此链表中先获取到此属性,再将该属性删除.

生产者和消费者线程的分析:在一个长度为10的容量池中,有两个队列对容量池进行操作,A队列负责往容量池中添加属性,B队列负责将容量池中的属性删除掉.此时要考虑的问题:

1.当容量池中的属性数量大于10的时候,那么此时A队列就不能添加属性,此时A队列必须等待:B队列消费容量池中的属性后A队列才可以对容量池进行继续添加;当容量池中的属性值个数为0的时候,B队列必须进入等待:A队列生产出属性后,B队列才能够继续消费. 这个就要用到线程的wait()和notify()方法,调用等待对不能进行操作的线程阻塞,当生产完成后,调用通知方法对等待的线程进行通知,确保阻塞的线程能够继续执行.
2.在A队列生产资源的时候,B队列此时不能使用,只有当资源全部生产完成后,B队列才能够使用资源.这个要用到synchronized关键字对当前的生产对象加锁.

下面一个简单的生产者消费者实例:
生产者

public class Producer implements Runnable {

    private EventStorage storge;

    public Producer(EventStorage storage) {
        this.storge = storage;
    }

    @Override
    public void run() {

        for (int i = 0; i < 10; i++) {
            storge.set();
        }

    }

}

消费者

public class Consumer implements Runnable {

    private EventStorage storage;

    public Consumer(EventStorage storage) {
        this.storage = storage;
    }

    @Override
    public void run() {

        for (int i = 0; i < 10; i++) {
            storage.get();
        }

    }
}

事件存储消费

public class EventStorage {

    private int maxSize;

    private List<String> storage;

    public EventStorage() {
        maxSize = 10;
        storage = new LinkedList<String>();
    }

    public synchronized void set() {
        while (storage.size() == maxSize) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        storage.add(UUID.randomUUID().toString());
        System.out.println(storage.size());
        notifyAll();
    }

    public synchronized void get() {
        while (storage.size() == 0) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        System.out.println(((LinkedList<?>) storage).poll());
        notifyAll();
    }

    public int getMaxSize() {
        return maxSize;
    }

    public void setMaxSize(int maxSize) {
        this.maxSize = maxSize;
    }

    public List<String> getStorage() {
        return storage;
    }

    public void setStorage(List<String> storage) {
        this.storage = storage;
    }

}

测试

    public static void main(String[] args) {
        EventStorage storage = new EventStorage();
        Producer producer = new Producer(storage);
        Thread thread1 = new Thread(producer);

        Consumer consumer = new Consumer(storage);
        Thread thread2 = new Thread(consumer);

        thread2.start();
        thread1.start();
    }