diff --git a/src/sf_service.c b/src/sf_service.c
index b80d3b5..67f5c15 100644
--- a/src/sf_service.c
+++ b/src/sf_service.c
@@ -678,6 +678,17 @@ struct nio_thread_data *sf_get_random_thread_data_ex(SFContext *sf_context)
     return sf_context->thread_data + index;
 }
 
+void sf_notify_all_threads_ex(SFContext *sf_context)
+{
+    struct nio_thread_data *tdata;
+    struct nio_thread_data *tend;
+
+    tend = sf_context->thread_data + sf_context->work_threads;
+    for (tdata=sf_context->thread_data; tdata<tend; tdata++) {
+        ioevent_notify_thread(tdata);
+    }
+}
+
 void sf_set_sig_quit_handler(sf_sig_quit_handler quit_handler)
 {
     sig_quit_handler = quit_handler;
diff --git a/src/sf_service.h b/src/sf_service.h
index 4eab6fd..c4b7c4c 100644
--- a/src/sf_service.h
+++ b/src/sf_service.h
@@ -105,6 +105,13 @@ struct nio_thread_data *sf_get_random_thread_data_ex(SFContext *sf_context);
 #define sf_get_random_thread_data()  \
     sf_get_random_thread_data_ex(&g_sf_context)
 
+
+void sf_notify_all_threads_ex(SFContext *sf_context);
+
+#define sf_notify_all_threads()  \
+    sf_notify_all_threads_ex(&g_sf_context)
+
+
 void sf_set_sig_quit_handler(sf_sig_quit_handler quit_handler);
 
 int sf_init_task(struct fast_task_info *task);