我是刚来高朗机械的,下面是代码上的doc开始工作的机械工人
worker := server.NewWorker("worker_name", 10)
err := worker.Launch()
if err != nil {
// do something with the error
}
我的第一个问题是,是吗 server.NewWorker("worker_name", 10)
启动10个工人?或者它意味着别的,如果不是,我如何启动10个工人如果需要,运行 go run example/machinery.go worker
10次?
我的第二个问题与第一个参数consumertag有关,在哪里可以找到使用的位置标记?
谢谢
1条答案
按热度按时间ssm49v7z1#
不,这行:
开始一个新的工作者。您需要运行多个示例来启动新的worker。10是特定worker将要运行的并发goroutine数。如果队列中有10个任务,它们可以同时运行。
对于标记,您需要检查代码库中每个代理的具体实现。