Reservoirs and parallelism

由于_push event, pull data_模型和多線程情況下，觀察者可能看不到數(shù)據(jù)全部的更新記錄(ps:因?yàn)榭偸谦@取最新的數(shù)據(jù))。這是特意設(shè)計(jì)的: 因?yàn)榇蠖鄶?shù)情況下(尤其更新app UI), 本來(lái)就只需要關(guān)心最新的數(shù)據(jù)。 然而, 如果客戶端(一般很少)想知道全部的變化歷史記錄, Agera 提供Repository的子類型: Reservoir，可以滿足這種場(chǎng)景。

Reservoir是一個(gè)響應(yīng)版本隊(duì)列。數(shù)據(jù)可以通過(guò)Receiver接口加入隊(duì)列，然后發(fā)起通知事件，然后觀察者可以從隊(duì)列中讀取數(shù)據(jù)(Repository.get())。

Reservoir隊(duì)列的訪問(wèn)是完全同步的，所以不會(huì)出現(xiàn)兩個(gè)客戶端從隊(duì)列中讀取到同一個(gè)數(shù)據(jù)(ps:就是線程安全)。 如果相同的值放入隊(duì)列多次，這也會(huì)認(rèn)為是不同的實(shí)例(ps:就是會(huì)生成多次通知事件)。

if the same value (the same Java object reference) is enqueued multiple times, they are different instances in the context of a reservoir).

返回?cái)?shù)據(jù)類型是Result, 所以如果客戶端嘗試從空隊(duì)列讀取數(shù)據(jù)的時(shí)候，可以接收Result.absent()作為一個(gè)失敗的通知。

基于這種行為，Reservoir非常適合必須處理事件源的每一個(gè)數(shù)據(jù)的響應(yīng)。 這種響應(yīng)可以使用[[compiled repository|Compiled-repositories]]實(shí)現(xiàn)。

如果合適的話，可以用Reservoir作為事件源，使用.attemptGetFrom(reservoir).orSkip()作為數(shù)據(jù)處理流程的開始指令。

一旦repository激活，Reservoir中的觀察者模式就會(huì)建立好(ps:消費(fèi)者和生產(chǎn)者的模式)。

使用Reservoir可以實(shí)現(xiàn)簡(jiǎn)單的并行任務(wù)，使用多個(gè)repository提供事件源和數(shù)據(jù)源，任務(wù)放入隊(duì)列，然后每個(gè)repository去執(zhí)行數(shù)據(jù)處理流程。

注意：為了做到并行執(zhí)行，repository都需要提交到線程池執(zhí)行或者運(yùn)行在不同的工作Looper(worker Loopers)。