转载请注明出处：

参考网址：

 

1. addjob简单示例

参考网址中给出了torch中threads的addjob函数使用方法：

local threads = require 'threads'local nthread = 4local njob = 10local msg = "hello from a satellite thread"local pool = threads.Threads(   nthread,   function(threadid)      print('starting a new thread/state number ' .. threadid)      gmsg = msg -- get it the msg upvalue and store it in thread state   end)local jobdone = 0for i=1,njob do   pool:addjob(      function()  -- note1         print(string.format('%s -- thread ID is %x', gmsg, __threadid))         return __threadid      end,      function(id)         print(string.format("task %d finished (ran on thread ID %x)", i, id))         jobdone = jobdone + 1      end      -- note2   )endpool:synchronize()print(string.format('%d jobs done', jobdone))pool:terminate()

上面程序是一个简单的例子。

2. addjob传入参数

note1的地方，当该函数无输入参数时，直接那样写，同时note2处什么也不写。

如果note1的function需要传入参数，可以写上参数列表，同时在note2处加上参数。如下所示：

pool:addjob(   function(variable1, variable2, bariable3)  -- note1      -- code …   end,   function(id)      -- code …   end,   var1,    -- note2   var2,   var3)

3. addjob函数说明

addjob函数如下：

Threads:addjob([id], callback, [endcallback], [...])

callback为在队列线程中执行的函数，endcallback为在主线程中执行的函数。