ReactiveTasks:由RxJava驱动的基于优先级的taskjob队列

时间:2024-05-31 05:51:02
【文件属性】:

文件名称:ReactiveTasks:由RxJava驱动的基于优先级的taskjob队列

文件大小:37KB

文件格式:ZIP

更新时间:2024-05-31 05:51:02

reactivex rxjava job-scheduler priority-queue rxjava2

介绍 有时,有必要在资源的用户之间共享资源,以便按顺序对其进行访问。 例如,如果您通过发送文本命令通过串行端口与Arduino设备通信,则您无法插入您的消息,而仅在传递上一条消息时才需要开始一条新消息。 这可能会导致代码复杂,尤其是如果您需要不断重复某些消息而不阻塞其他消息时,尤其如此。 该库允许利用RxJava简化此类资源共享。 例子 不会产生结果的任务 假设我们需要通过串行端口向Arduino发送控制LED的命令。 为了确保命令不会干扰,让我们将其转换为任务: // We use Void here because the task does not produce any results class SwitchLedTask implements Task< Void> { private final int ledId; private final boole


【文件预览】:
ReactiveTasks-master
----.gitignore(1KB)
----src()
--------main()
--------test()
----LICENSE(34KB)
----pom.xml(3KB)
----README.md(6KB)
----.editorconfig(52B)

网友评论