Searched refs:numThreads (Results 1 – 5 of 5) sorted by relevance
46 private static void timeContention(int numThreads) throws Exception { in timeContention() argument49 final ObtainThread[] threads = new ObtainThread[numThreads]; in timeContention()50 for (int i = 0; i < numThreads; i++) { in timeContention()51 final ObtainThread thread = new ObtainThread(ITERATIONS / numThreads); in timeContention()55 for (int i = 0; i < numThreads; i++) { in timeContention()
89 int numThreads = 2 * callbackCount; in testAddCallbackRemoveCallback_concurrently() local91 CountDownLatch threadsDone = new CountDownLatch(numThreads); in testAddCallbackRemoveCallback_concurrently()98 for (int i = 0; i < numThreads; i++) { in testAddCallbackRemoveCallback_concurrently()
220 int numThreads = SIZE - 2; in testRemoveChannelNotifications_concurrently() local223 CountDownLatch threadsDone = new CountDownLatch(numThreads); in testRemoveChannelNotifications_concurrently()224 for (int i = 0; i < numThreads; i++) { in testRemoveChannelNotifications_concurrently()
191 final int numThreads = 2; in testKeyValue_ReadRemoveConcurrency() local193 final CyclicBarrier barrier = new CyclicBarrier(numThreads); in testKeyValue_ReadRemoveConcurrency()196 for (int threadId = 0; threadId < numThreads; threadId++) { in testKeyValue_ReadRemoveConcurrency()
189 public static final native void setMaxThreads(int numThreads); in setMaxThreads() argument