Add mutex for saving process

yiisoft · Jun 18, 2023 · 49f28e9 · 49f28e9
1 parent 862587f
commit 49f28e9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/composer.json b/composer.json
@@ -34,6 +34,7 @@
         "yiisoft/di": "^1.0",
         "yiisoft/files": "^2.0",
         "yiisoft/json": "^1.0",
+        "yiisoft/mutex": "^1.1",
         "yiisoft/profiler": "^3.0",
         "yiisoft/proxy": "^1.0.1",
         "yiisoft/strings": "^2.0",

diff --git a/src/Debugger.php b/src/Debugger.php
@@ -5,6 +5,7 @@
 namespace Yiisoft\Yii\Debug;
 
 use Psr\Http\Message\ServerRequestInterface;
+use Yiisoft\Mutex\Synchronizer;
 use Yiisoft\Strings\WildcardPattern;
 use Yiisoft\Yii\Console\Event\ApplicationStartup;
 use Yiisoft\Yii\Debug\Collector\CollectorInterface;
@@ -13,12 +14,15 @@
 
 final class Debugger
 {
+    public const SAVING_MUTEX_NAME = self::class;
+
     private bool $skipCollect = false;
     private bool $active = false;
 
     public function __construct(
         private DebuggerIdGenerator $idGenerator,
         private StorageInterface $target,
+        private Synchronizer $synchronizer,
         /**
          * @var CollectorInterface[]
          */
@@ -64,7 +68,9 @@ public function shutdown(): void
 
         try {
             if (!$this->skipCollect) {
-                $this->target->flush();
+                $this->synchronizer->execute(self::SAVING_MUTEX_NAME . $this->idGenerator->getId(), function () {
+                    $this->target->flush();
+                });
             }
         } finally {
             foreach ($this->collectors as $collector) {