データベースにMonoを購読してディスポーザブルを保存する

Question

私は現在reactor-coreを探しています。私はMonoを購読することができ、購読者の実行を処理するために使い捨てを保存することもできます。

Mono<Object> task1 = Mono.just("Task1"); 
Mono<Object> task2 = Mono.just("Task2"); 
System.out.println(System.currentTimeMillis()); 
HashMap<Mono,Disposable> taskHandlerMap = new HashMap<>(); 
Disposable task1Handler = task1.delayElement(Duration.ofSeconds(5)).subscribe(
(Object x)->{ 
     System.out.println(x.toString() + "\t" + System.currentTimeMillis()); 
}); 
taskHandlerMap.put(task1,task1Handler); 
Disposable task2Handler = task2.delayElement(Duration.ofSeconds(10)).subscribe(
(Object x)->{ 
     System.out.println(x.toString() + "\t" + System.currentTimeMillis()); 
}); 
taskHandlerMap.put(task2,task2Handler); 

次のように、ハンドラマップを使用してスケジュールされたタスクを処分することができます。

taskHandlerMap.get(task2).dispose(); 

このtaskHandlerMapをデータベースに保存できますか？はい、どうすれば保存できますか？そうでなければ、サブスクリプションで作成された使い捨て品を保管する良い方法があります。

Answer 1

@akarnokdが指摘するように、Disposableは実際の計算の参照に過ぎず、試して保存してデータベースとの間で復元するのは意味がありません。

ExecutorServiceに長いHTTPコールを送信し、FutureをDBに保存して何らかの形でそれを復元できるとしたらどうでしょう...アプリケーションが停止すると、HTTPコールはとにかく消えてしまいます。アプリケーションが稼働し続けている場合は、FutureをDBに保存する必要はありません（HTTP呼び出しと同じ寿命でメモリに保存しておきます）。