文件名称:resource-scheduler:资源调度器
文件大小:18KB
文件格式:ZIP
更新时间:2024-06-28 07:19:53
Java
资源调度器 应用程序接口 资源处理程序应该可以配置为网关后面可用的资源数量。 API 应该很简单,提供一个将 Message 接口作为参数的“发送”方法。 send 方法的目的是将对象添加到队列中,并且在添加的同时,转发线程也应该处于活动状态,以允许资源调度程序的用户继续发送和排队消息。 资源调度器处理的消息对象应该实现 InternalMessage 接口。 同步与异步网关 假设网关是同步的,因此对 Gateway.send(Message) 的调用是阻塞的,为了发送 1 个以上的消息由 1 个以上的资源处理,应该使用线程。 每个阻塞发送方法调用一个线程。 但是必须创建一个线程池,以避免总是创建新线程。 线程池应具有与可配置固定数量的远程资源相同的可配置固定大小。 根据异步网关的假设,资源调度器应该有一种方法可以反馈每个消息的处理完成情况。 资源调度器应该维护可用资源的数量,并且: 1
【文件预览】:
resource-scheduler-master
----src()
--------test()
--------main()
----README.md(3KB)
----pom.xml(1KB)