如何启动多名机械工人?

问题描述

我是golang Machinery的新手,以下是文档中用于启动工作人员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名工人?或者这意味着其他事情,如果没有,我如何在需要时启动10个工作程序,运行go run example/machinery.go worker 10次?

我的第二个问题与第一个参数ConsumerTag有关,在哪里可以找到所使用的位置标签

谢谢

解决方法

不,这一行:

p=Product.objects.filter()

开始新的工作人员。您需要运行多个实例以启动新工作线程。 10是特定工作程序将要运行的并发goroutine的数量。如果队列中有10个任务,它们可以同时运行。

对于代码,您需要检查代码库中每个代理的具体实现。