From 043f50aa9efb70e5f8ec4863312ea4dd1db8c1b1 Mon Sep 17 00:00:00 2001
From: Amandeep Singh Chauhan <amandeepsinghchauhan5@gmail.com>
Date: Tue, 11 Nov 2025 21:04:37 +0530
Subject: [PATCH] Update patcher.py

---
 .../algorithms/genetic/patcher.py             | 40 +++++++++++++++++++
 1 file changed, 40 insertions(+)

diff --git a/WeatherRoutingTool/algorithms/genetic/patcher.py b/WeatherRoutingTool/algorithms/genetic/patcher.py
index 63d0b88..2d460ce 100644
--- a/WeatherRoutingTool/algorithms/genetic/patcher.py
+++ b/WeatherRoutingTool/algorithms/genetic/patcher.py
@@ -16,6 +16,46 @@
 from WeatherRoutingTool.utils.maps import Map
 from WeatherRoutingTool.weather import WeatherCond
 from WeatherRoutingTool.weather_factory import WeatherFactory
+import threading  
+import os         # already present above
+
+class SingletonBase(type):
+    """
+    Thread-safe, fork-safe Singleton metaclass.
+
+    - Per-class locks to serialize first construction only.
+    - Double-checked to avoid taking the lock on fast path.
+    - Fork-safe: if PID changes (after fork), instance is rebuilt in the child.
+    """
+    _instances: dict = {}
+    _locks: dict = {}
+    _pids: dict = {}
+
+    def __call__(cls, *args, **kwargs):
+        pid = os.getpid()
+        inst = cls._instances.get(cls)
+        if inst is not None and cls._pids.get(cls) == pid:
+            return inst
+
+        # Ensure a dedicated lock per singleton class
+        lock = cls._locks.setdefault(cls, threading.Lock())
+        with lock:
+            # Re-check after acquiring the lock
+            inst = cls._instances.get(cls)
+            if inst is None or cls._pids.get(cls) != pid:
+                inst = super().__call__(*args, **kwargs)
+                cls._instances[cls] = inst
+                cls._pids[cls] = pid
+        return inst
+
+    # Optional convenience for tests or controlled re-initialization
+    def clear_instance(cls):
+        """Clear the stored singleton instance (e.g., in tests)."""
+        lock = cls._locks.setdefault(cls, threading.Lock())
+        with lock:
+            cls._instances.pop(cls, None)
+            cls._pids.pop(cls, None)
+
 
 logger = logging.getLogger("WRT.genetic.patcher")