我目前正在探索reactor-core。我能够订阅一个单声道,也可以节省一次性处理执行的订阅者。
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保存在数据库中吗?是,我怎样才能保存它。否则,有没有更好的方法来存储订阅时创建的一次性文件。
https://stackoverflow.com/questions/47692305
复制相似问题