异步设计模式之生产者消费者

• 异步：将产生结果的类（生产者）与获取结果的类（消费者）解耦，生产者专注于生产，消费者专注于消费
• 采用消息队列来平衡生产者和消费者线程资源，不需要在一一对应了
• 队列满则生产者不在生产，队列空则消费者停止消费

//消息队列类，Java线程之间通信
class MessageQuque {//消息队列集合
    private LinkedListlist = new LinkedList<>();
    //队列容量
    private int capcity;

    public MessageQuque(int capcity) {this.capcity = capcity;
    }

    //获取消息
    public Message take() {//检查队列是否为空
        synchronized (list) {while (list.isEmpty()) {try {list.wait();
                } catch (InterruptedException e) {e.printStackTrace();
                }
            }
            list.notifyAll();
            //从队列的头部获取消息并返回
            return list.removeFirst();
        }
    }

    //存入消息
    public void put(Message message) {synchronized (list) {//检查队列是否满了
            while (list.size() == capcity) {try {list.wait();
                } catch (InterruptedException e) {e.printStackTrace();
                }
            }
            list.addLast(message);
            list.notifyAll();
        }
    }
}

final class Message {private int id;
    private Object value;

    public int getId() {return id;
    }

    public Object getValue() {return value;
    }

    public Message(int id, Object value) {this.id = id;
        this.value = value;
    }

    @Override
    public String toString() {return "Message{" +
                "id=" + id +
                ", value=" + value +
                '}';
    }
}

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧

为蛟河等地区用户提供了全套网页设计制作服务，及蛟河网站建设行业解决方案。主营业务为成都做网站、网站制作、蛟河网站设计，以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！
本文题目：异步设计模式之生产者消费者-创新互联
文章转载：http://pwwzsj.com/article/pjihj.html