异步设计模式之生产者消费者-创新互联

异步设计模式之生产者消费者
  • 异步:将产生结果的类(生产者)与获取结果的类(消费者)解耦,生产者专注于生产,消费者专注于消费
  • 采用消息队列来平衡生产者和消费者线程资源,不需要在一一对应了
  • 队列满则生产者不在生产,队列空则消费者停止消费
//消息队列类,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://myzitong.com/article/pjihj.html