diff --git a/Pool.php b/Pool.php
index 5567ee6..ba89ab0 100644
--- a/Pool.php
+++ b/Pool.php
@@ -14,31 +14,31 @@ use Exception;
 class Pool implements PoolInterface
 {
 
-	/** @var array<PoolItem> */
-	protected array $_connections = [];
+    /** @var array<PoolItem> */
+    protected array $_connections = [];
 
 
-	/**
-	 * @param $name
-	 * @param $retain_number
-	 * @throws Exception
-	 */
-	public function flush($name, $retain_number): void
-	{
-		if ($this->hasChannel($name)) {
+    /**
+     * @param $name
+     * @param $retain_number
+     * @throws Exception
+     */
+    public function flush($name, $retain_number): void
+    {
+        if ($this->hasChannel($name)) {
             $this->channel($name)->tailor($retain_number);
-		}
-	}
+        }
+    }
 
 
-	/**
-	 * @param PoolItem $channel
-	 * @param $retain_number
-	 */
-	protected function pop(PoolItem $channel, $retain_number): void
-	{
-		$channel->tailor($retain_number);
-	}
+    /**
+     * @param PoolItem $channel
+     * @param $retain_number
+     */
+    protected function pop(PoolItem $channel, $retain_number): void
+    {
+        $channel->tailor($retain_number);
+    }
 
 
     /**
@@ -46,40 +46,51 @@ class Pool implements PoolInterface
      * @param int $max
      * @param callable $closure
      */
-	public function created($name, int $max, callable $closure): void
-	{
-		if (!isset($this->_connections[$name])) {
-			$this->_connections[$name] = new PoolItem($max, $closure);
-		}
-	}
+    public function created($name, int $max, callable $closure): void
+    {
+        if (!isset($this->_connections[$name])) {
+            $this->_connections[$name] = new PoolItem($max, $closure);
+        }
+    }
 
 
-	/**
-	 * @param $name
-	 * @return PoolItem
-	 * @throws Exception
-	 */
-	public function channel($name): PoolItem
-	{
-		if (!isset($this->_connections[$name])) {
-			throw new Exception('Channel is not exists.');
-		}
-		$channel = $this->_connections[$name];
+    /**
+     * @param $name
+     * @return PoolItem
+     * @throws Exception
+     */
+    public function channel($name): PoolItem
+    {
+        if (!isset($this->_connections[$name])) {
+            throw new Exception('Channel is not exists.');
+        }
+        $channel = $this->_connections[$name];
         if ($channel->isClose()) {
             $channel->reconnect();
         }
         return $channel;
-	}
+    }
 
 
     /**
      * @param $name
      * @return bool
      */
-	public function hasChannel($name): bool
-	{
-		return isset($this->_connections[$name]) && $this->_connections[$name] instanceof PoolItem;
-	}
+    public function hasChannel($name): bool
+    {
+        return isset($this->_connections[$name]) && $this->_connections[$name] instanceof PoolItem;
+    }
+
+
+    /**
+     * @param string $name
+     * @return void
+     * @throws Exception
+     */
+    public function abandon(string $name): void
+    {
+        $this->channel($name)->abandon();
+    }
 
 
     /**
@@ -87,10 +98,10 @@ class Pool implements PoolInterface
      * @return array
      * @throws Exception
      */
-	public function get(string $name): mixed
-	{
-		return $this->channel($name)->pop();
-	}
+    public function get(string $name): mixed
+    {
+        return $this->channel($name)->pop();
+    }
 
 
     /**
@@ -98,50 +109,50 @@ class Pool implements PoolInterface
      * @return bool
      * @throws Exception
      */
-	public function isNull($name): bool
-	{
-		return $this->channel($name)->isEmpty();
-	}
+    public function isNull($name): bool
+    {
+        return $this->channel($name)->isEmpty();
+    }
 
 
-	/**
-	 * @param string $name
-	 * @param mixed $client
-	 * @return bool
-	 * 检查连接可靠性
-	 */
-	public function checkCanUse(string $name, mixed $client): bool
-	{
-		return true;
-	}
+    /**
+     * @param string $name
+     * @param mixed $client
+     * @return bool
+     * 检查连接可靠性
+     */
+    public function checkCanUse(string $name, mixed $client): bool
+    {
+        return true;
+    }
 
 
-	/**
-	 * @param string $name
-	 * @return bool
-	 */
-	public function hasItem(string $name): bool
-	{
-		$channel = $this->_connections[$name] ?? null;
-		if ($channel === null) {
-			return false;
-		}
-		return !$channel->isEmpty();
-	}
+    /**
+     * @param string $name
+     * @return bool
+     */
+    public function hasItem(string $name): bool
+    {
+        $channel = $this->_connections[$name] ?? null;
+        if ($channel === null) {
+            return false;
+        }
+        return !$channel->isEmpty();
+    }
 
 
-	/**
-	 * @param string $name
-	 * @return int
-	 */
-	public function size(string $name): int
-	{
-		$channel = $this->_connections[$name] ?? null;
-		if ($channel === null) {
-			return 0;
-		}
-		return $channel->size();
-	}
+    /**
+     * @param string $name
+     * @return int
+     */
+    public function size(string $name): int
+    {
+        $channel = $this->_connections[$name] ?? null;
+        if ($channel === null) {
+            return 0;
+        }
+        return $channel->size();
+    }
 
 
     /**
@@ -149,10 +160,10 @@ class Pool implements PoolInterface
      * @param mixed $data
      * @throws Exception
      */
-	public function push(string $name, mixed $data): void
-	{
-		$this->channel($name)->push($data);
-	}
+    public function push(string $name, mixed $data): void
+    {
+        $this->channel($name)->push($data);
+    }
 
 
     /**
@@ -161,35 +172,35 @@ class Pool implements PoolInterface
      * @return array
      * @throws Exception
      */
-	public function waite($name, int $time = 30): mixed
-	{
-		return $this->channel($name)->pop($time);
-	}
+    public function waite($name, int $time = 30): mixed
+    {
+        return $this->channel($name)->pop($time);
+    }
 
 
-	/**
-	 * @param string $name
-	 * @throws Exception
-	 */
-	public function close(string $name): void
-	{
-		$channel = $this->_connections[$name] ?? null;
-		if ($channel === null) {
-			return;
-		}
-		$channel->tailor(0);
-		$channel->close();
-	}
+    /**
+     * @param string $name
+     * @throws Exception
+     */
+    public function close(string $name): void
+    {
+        $channel = $this->_connections[$name] ?? null;
+        if ($channel === null) {
+            return;
+        }
+        $channel->tailor(0);
+        $channel->close();
+    }
 
 
-	/**
+    /**
      * return pool queue lists
-	 * @return PoolItem[]
-	 */
-	protected function channels(): array
-	{
-		return $this->_connections;
-	}
+     * @return PoolItem[]
+     */
+    protected function channels(): array
+    {
+        return $this->_connections;
+    }
 
 
     /**
diff --git a/PoolInterface.php b/PoolInterface.php
index 7e32349..8bd2970 100644
--- a/PoolInterface.php
+++ b/PoolInterface.php
@@ -22,6 +22,13 @@ interface PoolInterface
     public function get(string $name): mixed;
 
 
+    /**
+     * @param string $name
+     * @return void
+     */
+    public function abandon(string $name): void;
+
+
     /**
      * @param string $name
      * @param mixed $data
diff --git a/PoolItem.php b/PoolItem.php
index 673e501..00af038 100644
--- a/PoolItem.php
+++ b/PoolItem.php
@@ -76,7 +76,7 @@ class PoolItem
     public function push(mixed $item): void
     {
         if (is_null($item)) {
-            $item = call_user_func($this->callback);
+            return;
         }
         $this->_items->push($item);
     }
@@ -126,13 +126,23 @@ class PoolItem
     }
 
 
+    /**
+     * @return void
+     */
+    public function abandon(): void
+    {
+        $this->created -= 1;
+    }
+
+
     /**
      * @param int $waite
      * @return mixed
      */
     public function pop(int $waite = 10): mixed
     {
-        if ($this->_items->isEmpty()) {
+        if ($this->_items->isEmpty() && $this->created >= $this->maxCreated) {
+            $this->created += 1;
             return call_user_func($this->callback);
         } else {
             return $this->_items->pop($waite);