diff --git a/skynet-src/skynet_start.c b/skynet-src/skynet_start.c index cc582a68..a6a63e8b 100644 --- a/skynet-src/skynet_start.c +++ b/skynet-src/skynet_start.c @@ -125,7 +125,6 @@ _worker(void *p) { skynet_initthread(THREAD_WORKER); struct message_queue * q = NULL; for (;;) { - CHECK_ABORT q = skynet_context_message_dispatch(sm, q, weight); if (q == NULL) { if (pthread_mutex_lock(&m->mutex) == 0) { @@ -140,6 +139,7 @@ _worker(void *p) { } } } + CHECK_ABORT } return NULL; }