diff --git a/worker/worker.go b/worker/worker.go
index be4a657..f00fb9b 100644
--- a/worker/worker.go
+++ b/worker/worker.go
@@ -226,7 +226,10 @@ func (worker *Worker) customeHandler(inpack *inPack) {
 func (worker *Worker) Stop() {
 	// Set stopped flag
 	worker.stopped = true
+}
 
+// Wait for completeness serving
+func (worker *Worker) WaitRunning() {
 	// Wait for all the running activities has stopped
 	worker.active.Wait()
 }