go - 如何启动多名机械 worker ?

标签 go redis queue task

我是golang Machinery的新手,以下是doct上启动工machinery workers的代码

worker := server.NewWorker("worker_name", 10)
err := worker.Launch()
if err != nil {
  // do something with the error
}
我的第一个问题是,server.NewWorker("worker_name", 10)是否会启动10个 worker ?或者这意味着其他事情,如果不是,我如何在需要时启动10个工作程序,运行go run example/machinery.go worker 10次?
我的第二个问题与第一个参数ConsumerTag有关,在哪里可以找到所使用的位置标签?
谢谢

最佳答案

不,这行:

worker := server.NewWorker("worker_name", 10)
开始新工作。您需要运行多个实例以启动新工作线程。 10是特定工作程序将要运行的并发goroutine的数量。如果队列中有10个任务,它们可以同时运行。
对于标记,您需要检查代码库中每个代理的特定实现。

关于go - 如何启动多名机械 worker ?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63563296/

相关文章:

benchmarking - Go 语言基准测试?

python - redis.pipeline() 的局限性

redis - 有什么方法可以使用字符串作为 Redis 排序集 (zset) 中的分数?

c# - 测试非阻塞队列

algorithm - 使用队列实现栈——最好的复杂度

Go插件变量初始化

windows - 在 list 列表条目中获取 : no matching manifest for windows/amd64 10. 0.18362

php - 如何清除redis中键的值

java - 在Java中如何用数字元素和空格分割字符串并将其存储到可索引数组中?

go - key 未检索到的Golang map 值