尝试为Lua协程创建一个Process类。

2014-2-3 18:22:14
收藏：0
阅读：157
评论：2

我想找出一种通过将函数传递到对象中来创建对象的方法，并将其发送到一个协程，然后有一些函数，例如start（）stop（）和status（） 它可以像这样看起来，但我不知道如何实现这一点。

local Process = {}
Process.__index = Process

function newProcess(name,func)
  local self = setmetatable({}, Process)
  self.name = name
  self.func = func
  return self
end

这只是通过传递名称和函数来初始化过程。我想添加一些方法，如下所示。 （这是我需要实施的地方）

function Process:start()
  self.thread = -- create coroutine here
  self.thread -- Resume the coroutine here
end

使用函数变量“self.func”创建协程，然后启动协程。我在start函数中进行了初始化，以便可以多次运行它。这就是我遇到麻烦的地方

function Process:stop()
  -- Stops the running coroutine (shutdown or in case i need to end i)
end

我将来可能非常需要它，但我不知道如何实现它。基本上使用上面创建的self.thread变量

function Process:status()
  -- Maybe return the coroutine.status?
end

谢谢你的帮助。谢谢！

点赞
用户90511
用户90511

由于协程是一种协作式多任务处理形式，因此你不能那样做。这意味着每次只有一个协程在运行，并且将控制权从正在运行的协程转移回来的唯一方法是在适当的时候协程本身使用yield。

2014-02-03 21:17:48
用户869951
用户869951

你离成功很近了。协同程序是协作线程，所以您传递给进程的函数将不得不调用 coroutine.yield （理想状态下，经常调用）。另外，进程需要 resume()，以使“线程”可以继续工作。协同程序可以在未执行协同程序时随时从协同程序外部停止：只需不要恢复它并将其置为空。它可以在协程内随时停止，而无需暂停，而是返回。它看起来是这样的（没有经过测试以捕获错误）：

function Process:start()
    self.thread = coroutine.create(self.func)
    self:resume() -- 运行到下一个yield
end

function Process:resume()
    coroutine.resume(self.thread)
end

function Process:stop() -- 来自“外部”线程
    self.thread = nil
end

function Process:status()
  return coroutine.status(self.thread)
end

确保查看 Lua 参考手册 第 2.11 节 ，查看如何使用 coroutine.yield 构造函数示例，以及 第 5.2 节 以了解协程模块的详细信息。

您可以具有多个线程：

function func1() ... end
function func2() ... end
p1 = newProcess("func1", func1)
p2 = newProcess("func2", func2)
p1:start() -- 运行 func1 到其第一个 yield
p2:start() -- 运行 func2 到其第一个 yield
p1:resume() -- 运行 func1 到其第二个 yield
p2:resume() -- 运行 func2 到其第二个 yield

请注意，如果您具有以下 func1，则上述内容将无法正常工作：

function func1()
    sleep(100) -- 秒
end

但如果 func1 是这个，则可以正常工作：

function func1()
    for i=1,100 do
         sleep(1)
         coroutine.yield()
    end
end

两个版本都休眠相同的时间（100 秒），但第一个版本仅在 100 秒后返回，而第二个版本可以调用 100 次，这与单个核心多个线程产生相同的结果。注意：sleep 是伪代码，它在 Lua 中不可用； sleep 仅用于说明需要大量时间来完成可以分解为许多小块的内容的函数。

2014-02-03 21:19:46

作者:

用户3214283

用户3214283
推荐文章