fix: memory leak

djunny · Aug 11, 2020 · ab60473 · ab60473
1 parent c969b6c
commit ab60473
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 1 deletion.
diff --git a/src/MProcess.php b/src/MProcess.php
@@ -39,6 +39,14 @@ public function __construct($process = 5, $table_size = -1, $data_size = 1024) {
         $this->init();
     }
 
+    /**
+     * destroy memory
+     */
+    public function __destruct() {
+        $this->atomic_table->destroy();
+        $this->locker->destroy();
+    }
+
     /**
      * init table
      */
@@ -48,7 +56,6 @@ private function init() {
         $this->atomic_table = new Table($this->table_size);
         $this->atomic_table->column('id', Table::TYPE_INT, 4);
         $this->atomic_table->create();
-
         // lock
         $this->locker = new Lock();
     }

diff --git a/src/QueueTable.php b/src/QueueTable.php
@@ -42,6 +42,18 @@ public function __construct($size, $data_size) {
         $this->locker     = new Lock(SWOOLE_MUTEX);
     }
 
+    /**
+     * destroy memory
+     */
+    public function __destruct() {
+        $this->max_atomic = NULL;
+        $this->min_atomic = NULL;
+        $this->meta_table->destroy();
+        $this->locker->destroy();
+        $this->destroy();
+    }
+
+
     public function get_size() {
         return $this->memorySize + $this->meta_table->memorySize;
     }