sched.lua new_task()和run问题

[sandy1219]

local emitter_task = new_task(function() ...... end),不用调用emitter_task:run() 或者 sched.run(emitter_task ) 定时器就已经开始执行了，在new_task中 new_tasks[taskd] = true 这一步已经做了

run这个api 是不是应该是这样的 M.run = function ( task, ... ) local taskd if type(task)=='function' then taskd = new_task( task ) else taskd = task end new_tasks[taskd] = true; return taskd end 把new_tasks[taskd] = true 这行代码 从new_task中移除 加入到 run中 是不是更合适？

[sandy1219]

如果不这么改，chuck/minilumen/test/test-pause.lua 例子中 emitter_task 先于下边的sched运行，emitter_task第一次发出的 1 下边的sched是收不到的，这应该不是作者的意思吧

[sniperHW]

M.run = function ( task, ... )
    local taskd
    if type(task)=='function' then
        taskd = new_task( task )
    else
        taskd = task
    end
    --M.set_pause(taskd, false)
    --step_task(taskd, ...)  --FIXME can get the task killed: still in new_tasks
    return taskd
end

run并不会执行一个task,task是有sched.loop驱动执行的。 emitter_task:run()这行代码没有任何实际意义

要想第一个1不丢失，

sched.run(function()
    print("unkonw task")
    local waitd={timeout=5, 'ev'}
    while true do
        print("before wait")
        local ev, s = sched.wait(waitd)
        if ev then
            print(s)
        else
            print ('wakeup!')
            emitter_task:set_pause(false)
        end
    end
end)

emitter_task=sched.new_task(function()
    print("emitter_task")
    while true do
        for i=1, 5 do
            sched.signal('ev', i)
            sched.sleep(1)
        end
        sched.running_task:set_pause(true)
    end
end)

这样就行了。这样emitter_task就会在无名task之后运行了

[sandy1219]

如果我这么改 M.run = function ( task, ... ) local taskd if type(task)=='function' then taskd = new_task( task ) else taskd = task end new_tasks[taskd] = true; return taskd end new_tasks[taskd] = true; 这行代码从new_task api中删掉 加入到 run中

emitter_task:run() 或者 sched.run(emitter_task ) 会有问题么？

[sniperHW]

new_task的本意是创建一个task,在下次调用loop的时候运行，run的本意是立即执行。 但因为有bug原作者将run中立即执行的代码注释掉了。如果你这样改，new_task出来的task如果不调用run就永远不会被执行。这有背原意图。真正的问题在run中注释掉的代码。