Trying to solve issues with threads python.

Author: viferga

source/loaders/py_loader/include/py_loader/py_loader_threading.h

@@ -29,7 +29,7 @@
 extern "C" {
 #endif
 
-PY_LOADER_NO_EXPORT void py_loader_thread_initialize(const int host);
+PY_LOADER_NO_EXPORT int py_loader_thread_initialize(const int host);
 
 PY_LOADER_NO_EXPORT int py_loader_thread_is_main(void);
 

source/loaders/py_loader/source/py_loader_impl.c

@@ -2651,6 +2651,7 @@ loader_impl_data py_loader_impl_initialize(loader_impl impl, configuration confi
 #if DEBUG_ENABLED
 	int gc_initialized = 1;
 #endif
+	int gil_release;
 
 	if (py_impl == NULL)
 	{
@@ -2682,7 +2683,7 @@ loader_impl_data py_loader_impl_initialize(loader_impl impl, configuration confi
 	}
 
 	/* Initialize threading */
-	py_loader_thread_initialize(host);
+	gil_release = py_loader_thread_initialize(host);
 
 	/* Initialize executable */
 	if (py_loader_impl_initialize_sys_executable(py_impl) != 0)
@@ -2780,6 +2781,11 @@ loader_impl_data py_loader_impl_initialize(loader_impl impl, configuration confi
 	PyType_Modified(PyCFunctionTypePtr());
 #endif
 
+	if (gil_release)
+	{
+		py_loader_thread_release();
+	}
+
 	/* Register initialization */
 	loader_initialization_register(impl);
 
@@ -2823,6 +2829,10 @@ loader_impl_data py_loader_impl_initialize(loader_impl impl, configuration confi
 #endif
 error_after_argv:
 error_after_sys_executable:
+	if (gil_release)
+	{
+		py_loader_thread_release();
+	}
 	(void)py_loader_impl_finalize(py_impl, host);
 error_init_py:
 	free(py_impl);

source/loaders/py_loader/source/py_loader_threading.cpp

@@ -30,7 +30,7 @@ struct py_thread_state
 	PyGILState_STATE gstate;
 
 	py_thread_state() :
-		ref_count(0) {}
+		ref_count(0), gstate(PyGILState_UNLOCKED) {}
 
 	void ensure()
 	{
@@ -63,17 +63,30 @@ thread_local py_thread_state current_thread_state;
 thread_local uint64_t current_thread_id = thread_id_get_current();
 static std::vector<PyObject *> delayed_destructor;
 
-void py_loader_thread_initialize(const int host)
+int py_loader_thread_initialize(const int host)
 {
 	main_thread_id = thread_id_get_current();
 
 	if (host == 1)
 	{
+		int gil_status = PyGILState_Check();
+
 		PyGILState_STATE gstate = PyGILState_Ensure();
 		main_thread_state = PyThreadState_Get();
-		main_thread_ref_count++;
 		PyGILState_Release(gstate);
+
+		if (gil_status == 0)
+		{
+			py_loader_thread_acquire();
+			return 1;
+		}
+		else
+		{
+			main_thread_ref_count++;
+		}
 	}
+
+	return 0;
 }
 
 int py_loader_thread_is_main()