Searched refs:threadsCount (Results 1 – 6 of 6) sorted by relevance
213 uint32 threadsCount = MT_ARRAY_SIZE(threads); in SUITE() local215 printf("threads count %d\n", threadsCount); in SUITE()217 for(uint32 i = 0; i < threadsCount; i++) in SUITE()224 for(uint32 i = 0; i < threadsCount; i++) in SUITE()229 uint32 expectedSharedValue = (10000000 * threadsCount); in SUITE()
51 …threadsCount.StoreRelaxed( MT::Clamp(workerThreadsCount, (uint32)1, (uint32)MT_MAX_THREAD_COUNT) ); in TaskScheduler()141 threadsCount.Store(0); in JoinWorkerThreads()451 int32 totalThreadsCount = context.taskScheduler->threadsCount.LoadRelaxed(); in SchedulerFiberMain()636 int bucketIndex = ((roundRobinIndex + i) % threadsCount.LoadRelaxed()); in RunTasksImpl()698 int bucketIndex = roundRobinThreadIndex.IncFetch() % threadsCount.LoadRelaxed(); in RunTasksImpl()810 if (threadsCount.LoadRelaxed() <= (int32)minWorkersCount) in IsTaskStealingDisabled()820 return threadsCount.LoadRelaxed(); in GetWorkersCount()826 int32 threadsCount = GetWorkersCount(); in IsWorkerThread() local827 for (int32 i = 0; i < threadsCount; i++) in IsWorkerThread()902 void TaskScheduler::NotifyThreadsCreated(uint32 threadsCount) in NotifyThreadsCreated() argument[all …]
44 virtual void OnThreadsCreated(uint32 threadsCount) = 0;
304 Atomic32<int32> threadsCount; variable389 void NotifyThreadsCreated(uint32 threadsCount);
39 virtual void OnThreadsCreated(uint32 threadsCount) override in OnThreadsCreated() argument41 MT_UNUSED(threadsCount); in OnThreadsCreated()
163 uint32 threadsCount = (uint32)GetNumberOfHardwareThreads(); in GetAffinityMask() local164 for(uint32 i = 0; i < threadsCount; i++) in GetAffinityMask()