refactor: use levilamina's threadpool

Author: ShrBox

src/legacy/ThreadPool.h

@@ -254,7 +254,7 @@ Local<Value> FileClass::read(const Arguments& args) {
         int                      cnt = args[0].toInt();
         script::Global<Function> callbackFunc{args[1].asFunction()};
 
-        pool.enqueue(
+        pool.addTask(
             [cnt,
              fp{&file},
              isBinary{isBinary},
@@ -293,7 +293,7 @@ Local<Value> FileClass::readLine(const Arguments& args) {
     try {
         script::Global<Function> callbackFunc{args[0].asFunction()};
 
-        pool.enqueue([fp{&file}, lock{&lock}, callback{std::move(callbackFunc)}, engine{EngineScope::currentEngine()}](
+        pool.addTask([fp{&file}, lock{&lock}, callback{std::move(callbackFunc)}, engine{EngineScope::currentEngine()}](
                      ) {
             if ((ll::getServerStatus() != ll::ServerStatus::Running)) return;
             if (!EngineManager::isValid(engine)) return;
@@ -321,7 +321,7 @@ Local<Value> FileClass::readAll(const Arguments& args) {
     try {
         script::Global<Function> callbackFunc{args[0].asFunction()};
 
-        pool.enqueue([fp{&file},
+        pool.addTask([fp{&file},
                       isBinary{isBinary},
                       lock{&lock},
                       callback{std::move(callbackFunc)},
@@ -366,7 +366,7 @@ Local<Value> FileClass::write(const Arguments& args) {
         script::Global<Function> callbackFunc;
         if (args.size() >= 2) callbackFunc = args[1].asFunction();
 
-        pool.enqueue([fp{&file},
+        pool.addTask([fp{&file},
                       lock{&lock},
                       data{std::move(data)},
                       isString,
@@ -405,7 +405,7 @@ Local<Value> FileClass::writeLine(const Arguments& args) {
         script::Global<Function> callbackFunc;
         if (args.size() >= 2) callbackFunc = args[1].asFunction();
 
-        pool.enqueue([fp{&file},
+        pool.addTask([fp{&file},
                       lock{&lock},
                       data{std::move(data)},
                       callback{std::move(callbackFunc)},
@@ -487,7 +487,7 @@ Local<Value> FileClass::isEOF(const Arguments& args) {
 
 Local<Value> FileClass::flush(const Arguments& args) {
     try {
-        pool.enqueue([fp{&file}, lock{&lock}]() {
+        pool.addTask([fp{&file}, lock{&lock}]() {
             lock->lock();
             fp->flush();
             lock->unlock();

src/legacy/api/FileSystemAPI.cpp

@@ -103,7 +103,7 @@ Local<Value> FastLog(const Arguments& args) {
         std::ostringstream sout;
         for (int i = 0; i < args.size(); ++i) PrintValue(sout, args[i]);
 
-        pool.enqueue([str{sout.str()}, pluginName{ENGINE_OWN_DATA()->pluginName}]() {
+        pool.addTask([str{sout.str()}, pluginName{ENGINE_OWN_DATA()->pluginName}]() {
             ll::Logger fastLogger(pluginName);
             fastLogger.info(str);
         });

src/legacy/api/ScriptAPI.cpp

@@ -1,8 +1,8 @@
 #include "engine/LocalShareData.h"
 
-#include "ThreadPool.h"
 #include "main/Configs.h"
 
+#include <ll/api/thread/ThreadPool.h>
 #include <mutex>
 
 // DLL本地共享数据
@@ -12,7 +12,7 @@ LocalDataType* localShareData;
 std::vector<RegCmdQueue> toRegCmdQueue;
 
 // 线程池
-ThreadPool pool(LLSE_POOL_THREAD_COUNT);
+ll::thread::ThreadPool pool(LLSE_POOL_THREAD_COUNT);
 
 std::mutex messageLoopLock;
 

src/legacy/engine/LocalShareData.cpp

@@ -1,7 +1,7 @@
 #pragma once
-#include "ThreadPool.h"
 #include "api/APIHelp.h"
 
+#include <ll/api/thread/ThreadPool.h>
 #include <map>
 #include <mutex>
 #include <string>
@@ -54,7 +54,7 @@ extern LocalDataType* localShareData;
 extern std::vector<RegCmdQueue> toRegCmdQueue;
 
 // 线程池
-extern ThreadPool pool;
+extern ll::thread::ThreadPool pool;
 
 extern std::mutex messageLoopLock;