try to make threads better

Author: mastercoms

src/game/client/c_baseanimating.cpp

@@ -2746,7 +2746,7 @@ ConVar cl_warn_thread_contested_bone_setup("cl_warn_thread_contested_bone_setup"
 // Marked this developmentonly because it currently crashes, and users are enabling it and complaining because of
 // course.  Once this actually works it should just be FCVAR_INTERNAL_USE.
 // UNDONE(mastercoms)
-ConVar cl_threaded_bone_setup("cl_threaded_bone_setup", "0", FCVAR_INTERNAL_USE,
+ConVar cl_threaded_bone_setup("cl_threaded_bone_setup", "1", FCVAR_INTERNAL_USE,
                               "Enable parallel processing of C_BaseAnimating::SetupBones()" );
 
 //-----------------------------------------------------------------------------

src/tier0/threadtools.cpp

@@ -1260,24 +1260,26 @@ int CStdThreadEvent::WaitForMultiple(int nEvents, CStdThreadEvent* const* pEvent
 		}
 		else if (timeout != 0) // We still haven't timed out, so let's wait
 		{
+			#if 0
 			// If we're already signaled, skip adding listeners
 			int tries = 0;
 			int backoff = 1;
 			constexpr int iSpinCount = 1000;
 			do {
-				if (CheckSignaledAll(nEvents, pEvents))
-				{
-					bRet = true;
-					break;
-				}
 				for (int yields = 0; yields < backoff; yields++) {
 					ThreadPause();
 					tries++;
 				}
 				constexpr int kMaxBackoff = 64;
 				backoff = min(kMaxBackoff, backoff << 1);
+				if (CheckSignaledAll(nEvents, pEvents))
+				{
+					bRet = true;
+					break;
+				}
 			} while (tries < iSpinCount);
 			if (!bRet)
+			#endif
 			{
 				switch (nEvents)
 				{
@@ -1397,24 +1399,26 @@ int CStdThreadEvent::WaitForMultiple(int nEvents, CStdThreadEvent* const* pEvent
 		}
 		else if (timeout != 0) // Do it one more time under a lock to make sure.
 		{
+			#if 0
 			// If we're already signaled, skip adding listeners
 			int tries = 0;
 			int backoff = 1;
 			constexpr int iSpinCount = 1000;
 			do {
-				if (CheckSignaledAny(nEvents, pEvents, iEventIndex))
-				{
-					bRet = true;
-					break;
-				}
 				for (int yields = 0; yields < backoff; yields++) {
 					ThreadPause();
 					tries++;
 				}
 				constexpr int kMaxBackoff = 64;
 				backoff = min(kMaxBackoff, backoff << 1);
+				if (CheckSignaledAny(nEvents, pEvents, iEventIndex))
+				{
+					bRet = true;
+					break;
+				}
 			} while (tries < iSpinCount);
 			if (!bRet)
+			#endif
 			{
 				// Lock all at the same time, to prevent race conditions.
 				// Before, this was implemented by locking and checking for each one after the other, which caused a race condition.

src/vstdlib/jobthread.cpp

@@ -369,7 +369,11 @@ class CGlobalThreadPool : public CThreadPool
 		{
 			startParams.nThreads = nThreads;
 		}
-		startParams.iThreadPriority = TP_PRIORITY_LOW;
+		else
+		{
+			startParams.nThreadsMax = 6;
+		}
+		startParams.iThreadPriority = TP_PRIORITY_HIGH;
 		startParams.nStackSize = 128 * 1024;
 		return CThreadPool::Start( startParams, "Glob" );
 	}