From c5b99daa643c389bac84f200fec8ab7c959a785e Mon Sep 17 00:00:00 2001
From: kamhung <22250530@qq.com>
Date: Mon, 30 Nov 2015 17:54:40 +0800
Subject: [PATCH]

---
 src/com/wentch/redkale/util/ObjectPool.java | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/com/wentch/redkale/util/ObjectPool.java b/src/com/wentch/redkale/util/ObjectPool.java
index 6efae846d..9aa2f0447 100644
--- a/src/com/wentch/redkale/util/ObjectPool.java
+++ b/src/com/wentch/redkale/util/ObjectPool.java
@@ -77,9 +77,14 @@ public final class ObjectPool<T> implements Supplier<T> {
     public void offer(final T e) {
         if (e != null && recycler.test(e)) {
             if (cycleCounter != null) cycleCounter.incrementAndGet();
-            if (debug) queue.forEach(t -> {
-                if (t == e) logger.log(Level.WARNING, "[" + Thread.currentThread().getName() + "] repeat offer the same object(" + e + ")", new Exception());
-            });
+            if (debug) {
+                for (T t : queue) {
+                    if (t == e) {
+                        logger.log(Level.WARNING, "[" + Thread.currentThread().getName() + "] repeat offer the same object(" + e + ")", new Exception());
+                        return;
+                    }
+                }
+            }
             queue.offer(e);
         }
     }