| /dports/lang/mono-basic/mono-basic-4.7/vbnc/rt/source/ |
| H A D | TestExecutor.vb | 23 Private m_Threads() As Threading.Thread
58 ReDim m_Threads(3) '4 threads for now
135 For i As Integer = 0 To m_Threads.Length - 1
136 If m_Threads(i) IsNot Nothing Then Continue For
138 m_Threads(i).IsBackground = True
139 m_Threads(i).Start()
261 For i As Integer = 0 To m_Threads.Length - 1
262 Dim m_Thread As Threading.Thread = m_Threads(i)
281 For i As Integer = 0 To m_Threads.Length - 1
282 Dim m_Thread As Threading.Thread = m_Threads(i)
[all …]
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/util/ |
| H A D | thread_pool_old.cpp | 65 TACValue n2 = TACValue(m_Threads.size()); in KillAllThreads()
86 NON_CONST_ITERATE(TThreads, it, m_Threads) { in KillAllThreads()
93 m_Threads.clear(); in KillAllThreads()
106 m_Threads.push_back(CRef<TThread>(&thread)); in Register()
117 TThreads::iterator it = find(m_Threads.begin(), m_Threads.end(), in UnRegister()
119 if (it != m_Threads.end()) { in UnRegister()
121 m_Threads.erase(it); in UnRegister()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/util/ |
| H A D | thread_pool_old.cpp | 65 TACValue n2 = TACValue(m_Threads.size()); in KillAllThreads()
86 NON_CONST_ITERATE(TThreads, it, m_Threads) { in KillAllThreads()
93 m_Threads.clear(); in KillAllThreads()
106 m_Threads.push_back(CRef<TThread>(&thread)); in Register()
117 TThreads::iterator it = find(m_Threads.begin(), m_Threads.end(), in UnRegister()
119 if (it != m_Threads.end()) { in UnRegister()
121 m_Threads.erase(it); in UnRegister()
|
| /dports/science/InsightToolkit/ITK-5.0.1/Modules/Core/Common/src/ |
| H A D | itkThreadPool.cxx | 99 m_Threads.reserve( threadCount ); in ThreadPool()
102 m_Threads.emplace_back( &ThreadPool::ThreadExecute ); in ThreadPool()
111 m_Threads.reserve( m_Threads.size() + count ); in AddThreads()
114 m_Threads.emplace_back( &ThreadPool::ThreadExecute ); in AddThreads()
130 return int(m_Threads.size()) - int(m_WorkQueue.size()); // lousy approximation in GetNumberOfCurrentlyIdleThreads()
136 bool waitForThreads = !m_Threads.empty(); in ~ThreadPool()
164 for (ThreadIdType i = 0; i < m_Threads.size(); i++) in ~ThreadPool()
166 m_Threads[i].join(); in ~ThreadPool()
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netcache/test/check_nc_mirror/ |
| H A D | SimpleThreadPool.cpp | 6 m_Threads.push_back( thread ); in AddThread()
12 for_each( m_Threads.begin(), m_Threads.end(), [&]( CThread *thread ){ in WaitAll()
|
| H A D | SimpleThreadPool.h | 12 list< CThread* > m_Threads;
|
| /dports/net-mgmt/icinga2/icinga2-2.13.2/lib/base/ |
| H A D | io-engine.cpp | 87 …xt(), m_KeepAlive(boost::asio::make_work_guard(m_IoContext)), m_Threads(decltype(m_Threads)::size_… in IoEngine()
92 for (auto& thread : m_Threads) { in IoEngine()
99 for (auto& thread : m_Threads) { in ~IoEngine()
105 for (auto& thread : m_Threads) { in ~IoEngine()
|
| H A D | threadpool.cpp | 9 : m_Threads(threads), m_Pending(0) in ThreadPool()
24 m_Pool = decltype(m_Pool)(new boost::asio::thread_pool(m_Threads)); in Start()
|
| H A D | workqueue.cpp | 63 m_Threads.create_thread([this]() { WorkerThreadProc(); }); in EnqueueUnlocked()
120 m_Threads.join_all(); in Join()
|
| H A D | threadpool.hpp | 92 size_t m_Threads; member in icinga::ThreadPool
|
| H A D | io-engine.hpp | 131 std::vector<std::thread> m_Threads; member in icinga::IoEngine
|
| H A D | workqueue.hpp | 130 boost::thread_group m_Threads; member in icinga::WorkQueue
|
| /dports/games/0ad/0ad-0.0.23b-alpha/source/ps/ |
| H A D | Profiler2.cpp | 300 m_Threads.push_back(storage); in AddThreadStorage()
306 m_Threads.erase(std::find(m_Threads.begin(), m_Threads.end(), storage)); in RemoveThreadStorage()
729 for (size_t i = 0; i < m_Threads.size(); ++i) in ConstructJSONOverview()
733 stream << "{\"name\":\"" << CStr(m_Threads[i]->GetName()).EscapeToPrintableASCII() << "\"}"; in ConstructJSONOverview()
907 for (size_t i = 0; i < m_Threads.size(); ++i) in ConstructJSONResponse()
909 if (m_Threads[i]->GetName() == thread) in ConstructJSONResponse()
911 storage = m_Threads[i]; in ConstructJSONResponse()
943 threads = m_Threads; in SaveToFile()
|
| H A D | Profiler2.h | 457 std::vector<ThreadStorage*> m_Threads; // thread-safe; protected by m_Mutex variable
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/ |
| H A D | server.cpp | 303 NON_CONST_ITERATE(TThreads, it, m_Threads) { in KillAllThreads()
310 m_Threads.clear(); in KillAllThreads()
321 m_Threads.push_back(CRef<TThread>(&thread)); in Register()
331 TThreads::iterator it = find(m_Threads.begin(), m_Threads.end(), in UnRegister()
333 if (it != m_Threads.end()) { in UnRegister()
335 m_Threads.erase(it); in UnRegister()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/ |
| H A D | server.cpp | 303 NON_CONST_ITERATE(TThreads, it, m_Threads) { in KillAllThreads()
310 m_Threads.clear(); in KillAllThreads()
321 m_Threads.push_back(CRef<TThread>(&thread)); in Register()
331 TThreads::iterator it = find(m_Threads.begin(), m_Threads.end(), in UnRegister()
333 if (it != m_Threads.end()) { in UnRegister()
335 m_Threads.erase(it); in UnRegister()
|
| /dports/science/InsightToolkit/ITK-5.0.1/Modules/Core/Common/include/ |
| H A D | itkThreadPool.h | 105 return static_cast< ThreadIdType >( m_Threads.size() ); in GetMaximumNumberOfThreads()
143 std::vector< std::thread > m_Threads; variable
|
| /dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/tools/mediaserver/upnpsdk/Neptune/Source/Apps/ZipHttpServer/ |
| H A D | ZipHttpServer.cpp | 316 unsigned int m_Threads; member in ZipHttpServer
331 m_Threads(threads), in ZipHttpServer()
381 if (m_Threads == 1) { in Loop()
|
| /dports/multimedia/kodi/xbmc-19.3-Matrix/lib/libUPnP/Neptune/Source/Apps/ZipHttpServer/ |
| H A D | ZipHttpServer.cpp | 316 unsigned int m_Threads; member in ZipHttpServer
331 m_Threads(threads), in ZipHttpServer()
381 if (m_Threads == 1) { in Loop()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/connect/impl/ |
| H A D | thread_pool_for_server.hpp | 285 TThreads m_Threads; member in CPoolOfThreads_ForServer
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/connect/impl/ |
| H A D | thread_pool_for_server.hpp | 285 TThreads m_Threads; member in CPoolOfThreads_ForServer
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/pubseq_gateway/client/ |
| H A D | processing.cpp | 586 m_Threads.emplace_back(&BatchResolve::Reporter, ref(m_ReplyQueue), ref(m_JsonOut)); in CParallelProcessing()
588 m_Threads.emplace_back(&Interactive::Reporter, ref(m_ReplyQueue), ref(m_JsonOut)); in CParallelProcessing()
593 m_Threads.emplace_back([&]{ Retriever(m_PsgQueue, m_ReplyQueue); }); in CParallelProcessing()
598 … m_Threads.emplace_back(&BatchResolve::Submitter, ref(m_InputQueue), ref(m_PsgQueue), cref(args)); in CParallelProcessing()
600 …m_Threads.emplace_back(&Interactive::Submitter, ref(m_InputQueue), ref(m_PsgQueue), ref(m_JsonOut)… in CParallelProcessing()
|
| H A D | processing.hpp | 176 list<SThread> m_Threads; member in CParallelProcessing
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/vulkan_memory_allocator/src/VmaReplay/ |
| H A D | VmaReplay.cpp | 1639 std::unordered_map<uint32_t, Thread> m_Threads; member in Player
1745 const auto it = m_Threads.find(threadId); in ExecuteLine()
1746 if(it != m_Threads.end()) in ExecuteLine()
1754 m_Threads[threadId] = threadInfo; in ExecuteLine()
2624 const size_t threadCount = m_Threads.size(); in PrintStats()
2629 for(const auto& it : m_Threads) in PrintStats()
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/util/ |
| H A D | thread_pool_old.hpp | 676 TThreads m_Threads; member in CStdPoolOfThreads
|