基於rxjava的生產消費模型

一、前言 最近在看springcloud的熔斷機制的實現，發現底層使用的rxjava實現，就看了下rxjava的使用，發現rxjava使用可也便捷實現前面講解的定時生產與消費。 二、rxjava版生產消費實現 在簡單抽象下要實現的功能，定時器線程間隔3秒生成一個任務，假如任務裏面有3個子任務，則消費線程要分3秒，每秒消費一個子任務。 image.png prouducerTimer是一個定時器做生

>>阅读原文<<