最后用watch channel搞定了，多谢大神。

--
👇
johnmave126: 我记得tokio的sync::broadcast是你要的效果，但是不记得sync生态圈有没有类似的了

我记得tokio的sync::broadcast是你要的效果，但是不记得sync生态圈有没有类似的了

这么想确实是这么用的，牛，多谢大佬解惑。

--
👇
Easonzero: 用于任务级并行的, 多个相同的无上下文任务, 争抢输入数据, 并无序送输出.

--
👇
heliping: 看了github的issue，貌似确实不支持，

实在不明白如果广播不支持，那这个多对多的场景是什么？有点鸡肋。

Unfortunately, you can't. That would be possible using the bus crate.

Alternatively, you could create a channel per subscriber, hold a Vec<Sender<T>> on the producer side, and then send a copy of the message for each subscriber.

请问下，需要一个全局可变的变量。

因为是web后台的服务，开始和停止是不同的handler。需要共享一个全局的可变的共享变量。 这样worker轮询这个变量，停止的handler写着变量，然后worker读到就停止。 发现rust这个变量好难啊。 lazy和once_cell这种好像只支持一次初始化。

使用直接静态，报错，const call non-const。

--
👇
songzhi: 如果只是为了通知worker停止工作，搞一个原子变量worker那边去轮询或者条件变量worker那边去等待就可以了。

用于任务级并行的, 多个相同的无上下文任务, 争抢输入数据, 并无序送输出.

--
👇
heliping: 看了github的issue，貌似确实不支持，

实在不明白如果广播不支持，那这个多对多的场景是什么？有点鸡肋。

Unfortunately, you can't. That would be possible using the bus crate.

Alternatively, you could create a channel per subscriber, hold a Vec<Sender<T>> on the producer side, and then send a copy of the message for each subscriber.

看了github的issue，貌似确实不支持，

实在不明白如果广播不支持，那这个多对多的场景是什么？有点鸡肋。

Unfortunately, you can't. That would be possible using the bus crate.

Alternatively, you could create a channel per subscriber, hold a Vec<Sender<T>> on the producer side, and then send a copy of the message for each subscriber.

如果只是为了通知worker停止工作，搞一个原子变量worker那边去轮询或者条件变量worker那边去等待就可以了。