[NOSNOW] Correct server-connection.py in merge-decoder (#2958)

src/snowflake/snowpark/_internal/server_connection.py

@@ -51,6 +51,8 @@
 from snowflake.snowpark._internal.error_message import SnowparkClientExceptionMessages
 from snowflake.snowpark._internal.telemetry import TelemetryClient
 from snowflake.snowpark._internal.utils import (
+    create_rlock,
+    create_thread_local,
     escape_quotes,
     get_application_name,
     get_version,
@@ -171,8 +173,12 @@ def __init__(
             except TypeError:
                 pass
 
-        self._lock = threading.RLock()
-        self._thread_store = threading.local()
+        # thread safe param protection
+        self._thread_safe_session_enabled = self._get_client_side_session_parameter(
+            "PYTHON_SNOWPARK_ENABLE_THREAD_SAFE_SESSION", False
+        )
+        self._lock = create_rlock(self._thread_safe_session_enabled)
+        self._thread_store = create_thread_local(self._thread_safe_session_enabled)
 
         if "password" in self._lower_case_parameters:
             self._lower_case_parameters["password"] = None