updaet some logic

example/bench.php

@@ -0,0 +1,30 @@
+<?php
+
+use Swoft\Swlib\SwooleBench;
+
+require dirname(__DIR__) . '/src/SwooleBench.php';
+
+$swooleVersion = SWOOLE_VERSION;
+
+echo <<<EOF
+============================================================
+Swoole Version          {$swooleVersion}
+============================================================
+\n
+EOF;
+
+$bench = new SwooleBench([]);
+
+if (!$bench->initFromCli()) {
+    if ($error = $bench->getError()) {
+        $bench->println('Prepare Error:', $error);
+    }
+
+    exit(0);
+}
+
+$bench->run();
+
+if ($error = $bench->getError()) {
+    $bench->println('Run Error:', $error);
+}

src/AutoLoader.php

@@ -1,6 +1,6 @@
 <?php declare(strict_types=1);
 
-namespace Swlib;
+namespace Swoft\Swlib;
 
 use Swoft\Helper\ComposerJSON;
 use Swoft\SwoftComponent;

src/HttpClient.php

@@ -8,7 +8,7 @@
  * @license  https://github.com/swoft-cloud/swoft/blob/master/LICENSE
  */
 
-namespace Swoft\Swlib\Swoole;
+namespace Swoft\Swlib;
 
 use Swoft\Http\Message\ContentType;
 use Swoft\Http\Message\Response;

src/MemFactory.php

@@ -0,0 +1,11 @@
+<?php declare(strict_types=1);
+
+namespace Swoft\Swlib;
+
+/**
+ * Class MemFactory
+ */
+final class MemFactory
+{
+
+}

src/MemTable.php

@@ -8,7 +8,7 @@
  * @license  https://github.com/swoft-cloud/swoft/blob/master/LICENSE
  */
 
-namespace Swoft\Swlib\Swoole;
+namespace Swoft\Swlib;
 
 use InvalidArgumentException;
 use RuntimeException;
@@ -25,6 +25,8 @@
  */
 class MemTable
 {
+    public const KEY_FIELD = '__key';
+
     /**
      * Swoole memory table instance
      *
@@ -123,7 +125,7 @@ public function addColumn(string $name, int $type, int $size = 0): self
      */
     public function create(): bool
     {
-        if ($this->isCreate()) {
+        if ($this->isCreated()) {
             throw new RuntimeException('Memory table have been created, cannot recreated');
         }
 
@@ -136,6 +138,9 @@ public function create(): bool
             $this->table->column($name, $type, $size);
         }
 
+        // Append key column for storage key value.
+        $this->table->column(self::KEY_FIELD, Table::TYPE_STRING, 255);
+
         // Create memory table
         $result = $table->create();
 
@@ -159,10 +164,13 @@ public function create(): bool
      */
     public function set(string $key, array $data): bool
     {
-        if (!$this->isCreate()) {
+        if (!$this->isCreated()) {
             throw new RuntimeException('Memory table have not been create');
         }
 
+        // Append key column for storage key value.
+        $data[self::KEY_FIELD] = $key;
+
         return $this->getTable()->set($key, $data);
     }
 
@@ -249,14 +257,22 @@ public function count(): int
      ****************************************************************************/
 
     /**
-     * flush table
+     * clear/flush table data
      */
-    // public function flush(): void
-    // {
-    //     foreach ($this->table as $row) {
-    //         $this->table->del($row['key']);
-    //     }
-    // }
+    public function clear(): void
+    {
+        $this->flush();
+    }
+
+    /**
+     * clear/flush table data
+     */
+    public function flush(): void
+    {
+        foreach ($this->table as $row) {
+            $this->table->del($row[self::KEY_FIELD]);
+        }
+    }
 
     /**
      * Restore data from dbFile