better thread distribution

mastercoms · mastercoms · commit 027f6dd2c765 · 2020-10-22T04:13:52.000-04:00
diff --git a/public/vstdlib/jobthread.h b/public/vstdlib/jobthread.h
@@ -913,8 +913,11 @@ class CParallelProcessor
 
 			while( i-- )
 			{
-				jobs[i] = pThreadPool->QueueCall( this, &CParallelProcessor<ITEM_TYPE, ITEM_PROCESSOR_TYPE>::DoExecute );
+				jobs[i] = pThreadPool->QueueCall( this, JF_NO_ADD, &CParallelProcessor<ITEM_TYPE, ITEM_PROCESSOR_TYPE>::DoExecute );
 				jobs[i]->SetDescription( m_szDescription );
+				jobs[i]->SetServiceThread(i);
+				jobs[i]->SetFlags(JF_QUEUE);
+				pThreadPool->AddJob(jobs[i]);
 			}
 
 			// Do jobs alongside the threads

Original file line number	Diff line number	Diff line change
`@@ -913,8 +913,11 @@ class CParallelProcessor`
`913`	`913`
`914`	`914`	`while( i-- )`
`915`	`915`	`{`
`916`		`- jobs[i] = pThreadPool->QueueCall( this, &CParallelProcessor<ITEM_TYPE, ITEM_PROCESSOR_TYPE>::DoExecute );`
	`916`	`+ jobs[i] = pThreadPool->QueueCall( this, JF_NO_ADD, &CParallelProcessor<ITEM_TYPE, ITEM_PROCESSOR_TYPE>::DoExecute );`
`917`	`917`	`jobs[i]->SetDescription( m_szDescription );`
	`918`	`+ jobs[i]->SetServiceThread(i);`
	`919`	`+ jobs[i]->SetFlags(JF_QUEUE);`
	`920`	`+ pThreadPool->AddJob(jobs[i]);`
`918`	`921`	`}`
`919`	`922`
`920`	`923`	`// Do jobs alongside the threads`