竞争消费者

我想配置一个spring集成应用程序，这样如果我在一个通道上放置一些由一条消息表示的任务，那么一组端点中的一个将选择下一个任务并对其进行处理。这将需要一些线程池执行器服务，我想。     
2019-10-08 2 条评论
分享

没有找到相关结果

    已邀请:

    剿畦缄饥小

    是的，使用带有通道的调度程序+任务执行程序（也称为ExecutorChannel）。这样，使用调度程序的线程池将异步调用从通道消耗的任何端点（例如，
    service-activator
    ）。 在以下示例中，任何登陆到通道
    channel01
    的消息都将由
    jobLauncher
    服务在其中一个
    taskExecutor
    线程中使用。 
    <int:channel id="channel01">
    <int:dispatcher task-executor="taskExecutor">
</int:channel>

<task:executor id="taskExecutor" pool-size="2"/>

<int:service-activator input-channel="channel01" ref="jobLauncher">
        
    2019-10-08 0 0
    分享
    为什么被折叠? 0 个回复被折叠

    要回复问题请先登录或注册

    或代码 OrCode.com 备案号：粤ICP备15020848号-1
    Escape time: 0.033231973648071