多线程实现中的错误

请帮我找出多线程实现中的错误。

我正在尝试通过钩子实现多线程,钩子在n个迭代后发送lua_yield(L,0)到堆栈中,将主线程暂停,将控制权移交给第二个线程。 foo函数从主函数的主线程循环中运行一次,当在foo函数中调用yield()函数时,它将控制权移交给主线程(主函数),然后打开钩子,在n次后将暂停主线程(主函数),将控制权移交给第二个线程(foo函数)。一切都进行得很好,直到主线程的第150个迭代。请帮助理解错误的原因?

static int timerfirsttread = 0;//第一个线程的计时器。
void LUAHook(lua_State* L, lua_Debug* ar) {
  timerfirsttread++;
  if (timerfirsttread > 8) {
    timerfirsttread = 0;
    lua_yield(L, 0);
  }
};
int my_yield(lua_State* L) {
  int args = lua_gettop(L);args++;
  lua_State* L1 = lua_newthread(L);
  lua_pushthread(L1);
  return lua_yield(L, args);/*当C函数以这种形式调用lua_yield时,
  正在运行的协程将暂停其执行,运行调用 lua_resume 来恢复执行该协程。*/
};
int yield(lua_State* L) {return lua_yield(L, 0);/*res参数是从栈中返回的值的数量,
  它们将作为lua_resume的结果传递。*/
};
const char* LUA = R"(
  function foo(x) x = x or 3
    print(" func foo "..x.. " \n")
    for i = 1, x do
      print(" func foo "..i.."\n")
      yield()
    end
  end
  function main()
    for i = 1, 3220000 do
      z=i*6
      print(" func main "..i.."\n")
      if i ==1
      then my_yield(foo,10000036)
      end
    end end
    )";
  int main(int argc, char* argv[]) {
    lua_State* L = luaL_newstate();/*创建一个新的 Lua 状态。*/
    luaL_openlibs(L);
    lua_State* L1 = NULL;
    lua_register(L, "my_yield", my_yield);
    lua_register(L, "yield", yield);
    cout << "\n"; checkerror(L, LUA);
    lua_getglobal(L, "main");
    lua_resume(L, NULL, 0); /*在当前线程中启动并继续协程。*/
    L1 = lua_tothread(L, -1); lua_pop(L, 1); lua_xmove(L, L1,
      lua_gettop(L));lua_remove(L1, 1);
    int args = lua_gettop(L1);// cout << args << endl;//参数。
    for (int i = 1; i > args; i++) {lua_pushvalue(L1, i);}
    args--; lua_resume(L1, L, args); lua_xmove(L, L1, 1); //showstack(L1);
    while ( LUA_OK != lua_status(L)) { //直到主线程完成。
      if (LUA_YIELD == lua_status(L1)) {//如果第二个线程处于暂停状态。
        lua_sethook(L, LUAHook, LUA_MASKCOUNT, 6);//在6个迭代之后暂停。
        lua_resume(L, L1, 0);
        }//主程序
      if (LUA_YIELD == lua_status(L)){//如果主线程处于暂停状态。
        lua_sethook(L, LUAHook, LUA_MASKCOUNT, 0);//禁用钩子。
        lua_resume(L1, L, 0);//foo
      }
      if (LUA_OK == lua_status(L1)) {//如果foo线程完成。
        lua_sethook(L, LUAHook, LUA_MASKCOUNT, 0);//禁用钩子。
        lua_resume(L, NULL, 0);
      }
      if (LUA_OK == lua_status(L)) { break; }//如果主线程完成。
    };
    lua_close(L);
    return 0;
  };
点赞