diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerThread.java
index 13003cc0f82e60205c9ec87e364b869b0a2b6893..e834b22e86cbc9efe2f7ea4b804dcda96bb6909c 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerThread.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerThread.java
@@ -13,6 +13,7 @@ import java.io.StringWriter;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.TimeUnit;
 
 /**
  * handler thread
@@ -55,7 +56,7 @@ public class HandlerThread extends Thread{
 	public void run() {
 		while(!toStop){
 			try {
-				Map<String, String> handlerData = handlerDataQueue.take();
+				Map<String, String> handlerData = handlerDataQueue.poll(3L, TimeUnit.SECONDS);
 				if (handlerData!=null) {
 					i= 0;
 					String log_address = handlerData.get(HandlerParamEnum.LOG_ADDRESS.name());