diff --git a/src/threadpool.c b/src/threadpool.c index 2cb0d95bd1fe3df0c59176f9352fa86c53fc2861..875556e3f7d94a9ca2d8d2996110812c2aa21b18 100644 --- a/src/threadpool.c +++ b/src/threadpool.c @@ -37,7 +37,6 @@ #include #define MAX_THREADPOOL_SIZE 1024 -#define TASK_NUMBER_WARNING 1000 #define UV_TRACE_NAME "UV_TRACE" static uv_rwlock_t g_closed_uv_loop_rwlock; @@ -665,11 +664,6 @@ void uv__work_done(uv_async_t* handle) { QUEUE_APPEND(&lfields->wq_sub[i], &wq); } } - - if (loop->active_reqs.count > TASK_NUMBER_WARNING - && uv_check_data_valid((struct uv_loop_data*)(loop->data)) != 0) { - UV_LOGW("The number of task is too much, task number is %{public}u", loop->active_reqs.count); - } #endif uv_mutex_unlock(&loop->wq_mutex); diff --git a/src/unix/async.c b/src/unix/async.c index 32e3e531545af79fe2c1c20b6215131445761f77..91baec6cd2387ac81ea3dcf1e6458c2bd91ad725 100644 --- a/src/unix/async.c +++ b/src/unix/async.c @@ -141,6 +141,11 @@ static void uv__async_send(uv_async_t* handle) { int r; uv_loop_t* loop = handle->loop; + if (loop == NULL) { + UV_LOGE("fatal error! loop is NULL"); + return; + } + buf = ""; len = 1; fd = loop->async_wfd;