Home
last modified time | relevance | path

Searched refs:numThreads (Results 1 – 25 of 104) sorted by relevance

12345

/external/deqp/framework/delibs/decpp/
DdeSpinBarrier.cpp34 SpinBarrier::SpinBarrier (deInt32 numThreads) in SpinBarrier() argument
36 , m_numThreads (numThreads) in SpinBarrier()
41 DE_ASSERT(numThreads > 0); in SpinBarrier()
49 void SpinBarrier::reset (deUint32 numThreads) in reset() argument
53 DE_ASSERT(numThreads > 0); in reset()
54 m_numThreads = numThreads; in reset()
60 …rier::WaitMode getWaitMode (SpinBarrier::WaitMode requested, deUint32 numCores, deInt32 numThreads) in getWaitMode() argument
63 …return ((deUint32)numThreads <= numCores) ? SpinBarrier::WAIT_MODE_BUSY : SpinBarrier::WAIT_MODE_Y… in getWaitMode()
175 TestThread (SpinBarrier& barrier, volatile deInt32* sharedVar, int numThreads, int threadNdx) in TestThread() argument
178 , m_numThreads (numThreads) in TestThread()
[all …]
DdeAppendList.cpp62 SharedState (deUint32 numThreads, deUint32 numElements_, deUint32 numElementsHint) in SharedState()
64 , barrier (numThreads) in SharedState()
97 void runAppendListTest (deUint32 numThreads, deUint32 numElements, deUint32 numElementsHint) in runAppendListTest() argument
99 SharedState sharedState (numThreads, numElements, numElementsHint); in runAppendListTest()
100 vector<TestThreadSp> threads (numThreads); in runAppendListTest()
102 for (deUint32 threadNdx = 0; threadNdx < numThreads; ++threadNdx) in runAppendListTest()
108 for (deUint32 threadNdx = 0; threadNdx < numThreads; ++threadNdx) in runAppendListTest()
111 DE_TEST_ASSERT(sharedState.testList.size() == (size_t)numElements*(size_t)numThreads); in runAppendListTest()
114 vector<deUint32> countByThread (numThreads); in runAppendListTest()
124 DE_TEST_ASSERT(de::inBounds(elem.threadNdx, 0u, numThreads)); in runAppendListTest()
[all …]
/external/lzma/CPP/7zip/Common/
DMethodProps.h20 …MtProp(const UString &name, const PROPVARIANT &prop, UInt32 defaultNumThreads, UInt32 &numThreads);
131 int numThreads = Get_NumThreads(); in Get_Lzma_NumThreads() local
132 if (numThreads >= 0) in Get_Lzma_NumThreads()
133 return numThreads < 2 ? 1 : 2; in Get_Lzma_NumThreads()
140 int numThreads = Get_NumThreads(); in Get_Xz_NumThreads() local
141 if (numThreads >= 0 && numThreads <= 1) in Get_Xz_NumThreads()
145 return numThreads; in Get_Xz_NumThreads()
188 int numThreads = Get_NumThreads(); in Get_BZip2_NumThreads() local
189 if (numThreads >= 0) in Get_BZip2_NumThreads()
192 if (numThreads < 1) return 1; in Get_BZip2_NumThreads()
[all …]
/external/swiftshader/third_party/marl/src/
Dnon_marl_bench.cpp59 auto const numThreads = Schedule::numThreads(state); in SingleQueueTaskExecutor() local
99 for (int i = 0; i < numThreads; i++) { in SingleQueueTaskExecutor()
106 if (numThreads > 0) { in SingleQueueTaskExecutor()
127 auto const numThreads = Schedule::numThreads(state); in MultiQueueTaskExecutor() local
128 auto const numQueues = std::max(numThreads, 1); in MultiQueueTaskExecutor()
137 if (numThreads > 0) { in MultiQueueTaskExecutor()
143 for (int i = 0; i < numThreads; i++) { in MultiQueueTaskExecutor()
/external/tensorflow/tensorflow/lite/java/src/main/java/org/tensorflow/lite/
DInterpreter.java89 public Options setNumThreads(int numThreads) { in setNumThreads() argument
90 this.numThreads = numThreads; in setNumThreads()
137 int numThreads = -1; field in Interpreter.Options
164 public Interpreter(@NonNull File modelFile, int numThreads) { in Interpreter() argument
165 this(modelFile, new Options().setNumThreads(numThreads)); in Interpreter()
206 public Interpreter(@NonNull ByteBuffer byteBuffer, int numThreads) { in Interpreter() argument
207 this(byteBuffer, new Options().setNumThreads(numThreads)); in Interpreter()
412 public void setNumThreads(int numThreads) { in setNumThreads() argument
414 wrapper.setNumThreads(numThreads); in setNumThreads()
DNativeInterpreterWrapper.java72 this.interpreterHandle = createInterpreter(modelHandle, errorHandle, options.numThreads); in init()
192 void setNumThreads(int numThreads) { in setNumThreads() argument
193 numThreads(interpreterHandle, numThreads); in setNumThreads()
428 private static native void numThreads(long interpreterHandle, int numThreads); in numThreads() method in NativeInterpreterWrapper
440 private static native long createInterpreter(long modelHandle, long errorHandle, int numThreads); in createInterpreter() argument
/external/lzma/CPP/7zip/Compress/
DLzma2Decoder.cpp107 props.numThreads = 1; in Code()
108 UInt32 numThreads = _numThreads; in Code() local
110 if (_tryMt && numThreads >= 1) in Code()
123 if (numThreads > okThreads) in Code()
124 numThreads = (UInt32)okThreads; in Code()
125 if (numThreads == 0) in Code()
126 numThreads = 1; in Code()
127 props.numThreads = numThreads; in Code()
167 if (props.numThreads > 1) in Code()
198 STDMETHODIMP CDecoder::SetNumberOfThreads(UInt32 numThreads) in SetNumberOfThreads() argument
[all …]
DXzDecoder.cpp55 props.numThreads = 1; in Decode()
56 UInt32 numThreads = _numThreads; in Decode() local
58 if (_tryMt && numThreads > 1) in Decode()
64 isMT = (numThreads > 1); in Decode()
67 props.numThreads = numThreads; in Decode()
136 STDMETHODIMP CComDecoder::SetNumberOfThreads(UInt32 numThreads) in SetNumberOfThreads() argument
138 _numThreads = numThreads; in SetNumberOfThreads()
/external/tensorflow/tensorflow/lite/experimental/support/java/src/java/org/tensorflow/lite/support/model/
DModel.java52 private int numThreads = 1; field in Model.Builder
78 public Builder setNumThreads(int numThreads) { in setNumThreads() argument
79 this.numThreads = numThreads; in setNumThreads()
85 return new Model(modelPath, byteModel, device, numThreads); in build()
131 int numThreads) { in Model() argument
150 interpreterOptions.setNumThreads(numThreads); in Model()
/external/tensorflow/tensorflow/core/framework/
Ddevice_base_test.cc39 EXPECT_EQ(d->numThreads(), 16); in TEST()
45 EXPECT_EQ(d->numThreads(), 4); in TEST()
51 EXPECT_EQ(d->numThreads(), 1); in TEST()
57 EXPECT_EQ(d->numThreads(), 16); in TEST()
/external/tensorflow/tensorflow/lite/kernels/
Deigen_support_test.cc57 EXPECT_EQ(thread_pool_device->numThreads(), 4); in TEST()
69 EXPECT_EQ(thread_pool_device->numThreads(), 1); in TEST()
90 EXPECT_EQ(thread_pool_device->numThreads(), 2); in TEST()
110 EXPECT_EQ(thread_pool_device->numThreads(), 1); in TEST()
117 EXPECT_EQ(thread_pool_device->numThreads(), 3); in TEST()
/external/dagger2/javatests/dagger/functional/cycle/
DDoubleCheckCycleTest.java184 int numThreads = 10; in testGetFromMultipleThreads() local
185 CountDownLatch remainingTasks = new CountDownLatch(numThreads); in testGetFromMultipleThreads()
186 List<Thread> tasks = new ArrayList<>(numThreads); in testGetFromMultipleThreads()
187 List<Object> values = Collections.synchronizedList(new ArrayList<>(numThreads)); in testGetFromMultipleThreads()
190 for (int i = 0; i < numThreads; i++) { in testGetFromMultipleThreads()
211 while (waiting != numThreads) { in testGetFromMultipleThreads()
238 assertThat(values).isEqualTo(Collections.nCopies(numThreads, futureValue)); in testGetFromMultipleThreads()
/external/eigen/unsupported/Eigen/CXX11/src/Tensor/
DTensorDeviceThreadPool.h133 EIGEN_STRONG_INLINE int numThreads() const { in numThreads() function
186 if (n <= 1 || numThreads() == 1 || in parallelFor()
187 CostModel::numThreads(n, cost, static_cast<int>(numThreads())) == 1) { in parallelFor()
212 (divup<int>(block_count, numThreads()) * numThreads()); in parallelFor()
233 (divup<int>(coarser_block_count, numThreads()) * numThreads()); in parallelFor()
/external/mesa3d/src/gallium/drivers/swr/rasterizer/core/
Dthreads.cpp998 static void InitPerThreadStats(SWR_CONTEXT* pContext, uint32_t numThreads) in InitPerThreadStats() argument
1004 (SWR_STATS*)AlignedMalloc(sizeof(SWR_STATS) * numThreads, 64); in InitPerThreadStats()
1005 memset(pContext->dcRing[dc].dynState.pStats, 0, sizeof(SWR_STATS) * numThreads); in InitPerThreadStats()
1126 uint32_t numThreads = numNodes * numCoresPerNode * numHyperThreads; in CreateThreadPool() local
1127 SWR_REL_ASSERT(numThreads <= numHWThreads); in CreateThreadPool()
1136 numThreads = 1; in CreateThreadPool()
1140 pPool->numThreads = 0; in CreateThreadPool()
1144 numThreads = std::min(pContext->threadInfo.MAX_WORKER_THREADS, numHWThreads); in CreateThreadPool()
1152 if (numAPIReservedThreads >= numThreads) in CreateThreadPool()
1173 numThreads -= numRemovedThreads; in CreateThreadPool()
[all …]
/external/lzma/CPP/7zip/UI/Common/
DBench.cpp1170 numThreads in MethodBench()
1198 numEncoderThreads = numThreads; in MethodBench()
1202 if (numThreads == 1 && method.Get_NumThreads() < 0) in MethodBench()
1205 if (numThreads > 1 && numLzmaThreads > 1) in MethodBench()
1207 numEncoderThreads = numThreads / 2; in MethodBench()
1443 UInt64 GetBenchMemoryUsage(UInt32 numThreads, UInt32 dictionary, bool totalBench) in GetBenchMemoryUsage() argument
1447 bool lzmaMt = (totalBench || numThreads > 1); in GetBenchMemoryUsage()
1448 UInt32 numBigThreads = numThreads; in GetBenchMemoryUsage()
1934 bool size_Defined, UInt64 size, const char *threadsString, UInt32 numThreads) in PrintRequirements() argument
1954 PrintNumber(f, numThreads, 3); in PrintRequirements()
[all …]
/external/lzma/C/
DLzmaLib.c17 int numThreads /* 1 or 2, default = 2 */ in LzmaCompress() argument
28 props.numThreads = numThreads; in LzmaCompress()
DMtCoder.h18 #define MTCODER__GET_NUM_BLOCKS_FROM_THREADS(numThreads) ((numThreads) + (numThreads) / 8 + 1) argument
/external/dagger2/javatests/dagger/internal/
DDoubleCheckTest.java77 int numThreads = 10; in get() local
78 ExecutorService executor = Executors.newFixedThreadPool(numThreads); in get()
80 final CountDownLatch latch = new CountDownLatch(numThreads); in get()
84 List<Callable<Object>> tasks = Lists.newArrayListWithCapacity(numThreads); in get()
85 for (int i = 0; i < numThreads; i++) { in get()
/external/deqp/modules/egl/
DteglColorClearCase.cpp353 int numThreads = (int)contexts.size(); in executeForContexts() local
354 int numPackets = numThreads * numPacketsPerThread; in executeForContexts()
357 vector<vector<ClearPacket> > packets (numThreads); in executeForContexts()
358 vector<ColorClearThreadSp> threads (numThreads); in executeForContexts()
365 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
374 packet.wait = semaphores[packetNdx*numThreads + threadNdx]; in executeForContexts()
375 packet.signal = semaphores[packetNdx*numThreads + threadNdx + 1]; in executeForContexts()
389 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
414 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
420 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
/external/guava/android/guava-tests/test/com/google/common/base/
DSuppliersTest.java312 final int numThreads = 3; in testSupplierThreadSafe() local
313 final Thread[] threads = new Thread[numThreads]; in testSupplierThreadSafe()
344 while (waitingThreads() != numThreads - 1) { in testSupplierThreadSafe()
361 for (int i = 0; i < numThreads; i++) { in testSupplierThreadSafe()
399 final int numThreads = 10; in testSynchronizedSupplierThreadSafe() local
401 Thread[] threads = new Thread[numThreads]; in testSynchronizedSupplierThreadSafe()
402 for (int i = 0; i < numThreads; i++) { in testSynchronizedSupplierThreadSafe()
420 assertEquals(numThreads * iterations + 1, (int) nonThreadSafe.get()); in testSynchronizedSupplierThreadSafe()
/external/guava/guava-tests/test/com/google/common/base/
DSuppliersTest.java312 final int numThreads = 3; in testSupplierThreadSafe() local
313 final Thread[] threads = new Thread[numThreads]; in testSupplierThreadSafe()
344 while (waitingThreads() != numThreads - 1) { in testSupplierThreadSafe()
361 for (int i = 0; i < numThreads; i++) { in testSupplierThreadSafe()
399 final int numThreads = 10; in testSynchronizedSupplierThreadSafe() local
401 Thread[] threads = new Thread[numThreads]; in testSynchronizedSupplierThreadSafe()
402 for (int i = 0; i < numThreads; i++) { in testSynchronizedSupplierThreadSafe()
420 assertEquals(numThreads * iterations + 1, (int) nonThreadSafe.get()); in testSynchronizedSupplierThreadSafe()
/external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/
DAbstractFutureFootprintBenchmark.java48 int numThreads; field in AbstractFutureFootprintBenchmark
54 if (state != State.NOT_DONE && (numListeners != 0 || numThreads != 0)) { in setUp()
69 for (int i = 0; i < numThreads; i++) { in measureSize()
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DAbstractFutureFootprintBenchmark.java48 int numThreads; field in AbstractFutureFootprintBenchmark
54 if (state != State.NOT_DONE && (numListeners != 0 || numThreads != 0)) { in setUp()
69 for (int i = 0; i < numThreads; i++) { in measureSize()
/external/jemalloc/msvc/projects/vc2015/test_threads/
Dtest_threads.cpp32 static const int numThreads = narenas + 1, numAllocsMax = 25, numIter1 = 50, numIter2 = 50; in test_threads() local
39 printf("Starting %d threads x %d x %d iterations...\n", numThreads, numIter1, numIter2); in test_threads()
40 for (int i = 0; i < numThreads; i++) { in test_threads()
/external/jemalloc_new/msvc/test_threads/
Dtest_threads.cpp31 static const int numThreads = narenas + 1, numAllocsMax = 25, numIter1 = 50, numIter2 = 50; in test_threads() local
38 printf("Starting %d threads x %d x %d iterations...\n", numThreads, numIter1, numIter2); in test_threads()
39 for (int i = 0; i < numThreads; i++) { in test_threads()

12345