我是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/