From 4f3f5e849c6fb77520a3dd06c05c2e3c7ce21311 Mon Sep 17 00:00:00 2001 From: "xueli.xue" Date: Wed, 20 Jul 2016 11:10:48 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=9B=9E=E8=B0=83=E9=98=9F?= =?UTF-8?q?=E5=88=97,poll=E6=94=B9=E4=B8=BAtake;=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E4=B8=80=E5=A4=84=E5=8F=AF=E8=83=BD=E5=AF=BC=E8=87=B4cpu?= =?UTF-8?q?=E5=8D=A0=E6=BB=A1=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/xxl/job/core/handler/HandlerRepository.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerRepository.java b/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerRepository.java index 15762b35..e2865713 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerRepository.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/handler/HandlerRepository.java @@ -206,7 +206,7 @@ public class HandlerRepository { public void run() { while(true){ try { - HashMap item = callBackQueue.poll(); + HashMap item = callBackQueue.take(); if (item != null) { RemoteCallBack callback = null; try {