optimize code

swoole · May 9, 2024 · 9d59862 · 9d59862
1 parent b0cafc8
commit 9d59862
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/include/swoole_server.h b/include/swoole_server.h
@@ -464,10 +464,10 @@ class ThreadFactory : public BaseFactory {
   public:
     ThreadFactory(Server *server);
     ~ThreadFactory();
-    void spawn_event_worker(int i);
-    void spawn_task_worker(int i);
-    void spawn_user_worker(int i);
-    void spawn_manager_thread(int i);
+    void spawn_event_worker(WorkerId i);
+    void spawn_task_worker(WorkerId i);
+    void spawn_user_worker(WorkerId i);
+    void spawn_manager_thread(WorkerId i);
     void wait();
     bool start() override;
     bool shutdown() override;

diff --git a/src/server/thread.cc b/src/server/thread.cc
@@ -82,7 +82,7 @@ void ThreadFactory::create_thread(int i, _Callable fn) {
     threads_[i] = std::thread(fn);
 }
 
-void ThreadFactory::spawn_event_worker(int i) {
+void ThreadFactory::spawn_event_worker(WorkerId i) {
     create_thread(i, [=]() {
         swoole_set_process_type(SW_PROCESS_EVENTWORKER);
         swoole_set_thread_type(Server::THREAD_WORKER);
@@ -96,7 +96,7 @@ void ThreadFactory::spawn_event_worker(int i) {
     });
 }
 
-void ThreadFactory::spawn_task_worker(int i) {
+void ThreadFactory::spawn_task_worker(WorkerId i) {
     create_thread(i, [=]() {
         swoole_set_process_type(SW_PROCESS_TASKWORKER);
         swoole_set_thread_type(Server::THREAD_WORKER);
@@ -120,7 +120,7 @@ void ThreadFactory::spawn_task_worker(int i) {
     });
 }
 
-void ThreadFactory::spawn_user_worker(int i) {
+void ThreadFactory::spawn_user_worker(WorkerId i) {
     create_thread(i, [=]() {
         Worker *worker = server_->user_worker_list.at(i - server_->task_worker_num - server_->worker_num);
         swoole_set_process_type(SW_PROCESS_USERWORKER);
@@ -134,7 +134,7 @@ void ThreadFactory::spawn_user_worker(int i) {
     });
 }
 
-void ThreadFactory::spawn_manager_thread(int i) {
+void ThreadFactory::spawn_manager_thread(WorkerId i) {
     create_thread(i, [=]() {
         swoole_set_process_type(SW_PROCESS_MANAGER);
         swoole_set_thread_type(Server::THREAD_WORKER);