- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 375 for thread1 (0.3 sec)
-
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* there's another race: If the first thread fails with an exception and a second thread * immediately fails with the same exception: * * Thread1: calls setException(), which returns true, context switch before it can CAS * seenExceptions to its exception * * Thread2: calls setException(), which returns false, CASes seenExceptions to its exception,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* there's another race: If the first thread fails with an exception and a second thread * immediately fails with the same exception: * * Thread1: calls setException(), which returns true, context switch before it can CAS * seenExceptions to its exception * * Thread2: calls setException(), which returns false, CASes seenExceptions to its exception,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-create-syscall-reuse-thread-id.go
// in the trace have unique IDs, since the P just stays associated // with an eternally dead thread, and it's stolen by some other // thread later. But if thread IDs are reused, then the tracer // gets confused when trying to advance events on the new thread. // The now-dead thread which exited on a GoDestroySyscall still has // its P associated and this transfers to the newly-live thread
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 2.3K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestExecutor.groovy
logger.log "timeout waiting for ${threads.size()} threads to complete" threads.each { thread -> IllegalStateException e = new IllegalStateException("Timeout waiting for ${thread.name} to complete.") e.stackTrace = thread.stackTrace if (failure == null) { failure = e } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.9K bytes - Viewed (0) -
src/cmd/trace/threadgen.go
globalRangeGenerator globalMetricGenerator stackSampleGenerator[trace.ThreadID] logEventGenerator[trace.ThreadID] gStates map[trace.GoID]*gState[trace.ThreadID] threads map[trace.ThreadID]struct{} } func newThreadGenerator() *threadGenerator { tg := new(threadGenerator) rg := func(ev *trace.Event) trace.ThreadID { return ev.Thread() } tg.stackSampleGenerator.getResource = rg
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 5.7K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationQueueTest.groovy
} def "cleanup"() { lease?.leaseFinish() workerRegistry.stop() } def "executes all #runs operations in #threads threads"() { given: setupQueue(threads) def success = Mock(TestBuildOperation) when: runs.times { operationQueue.add(success) } and:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java
}); } for (Thread th : threads) { th.start(); } for (Thread th : threads) { th.join(); } assertEquals(num, count.get()); assertEquals(num, valueSet.size()); Set<String> valueSet2 = Collections.synchronizedSet(new HashSet<>()); threads = new Thread[threadNum];
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 8.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
final Thread[] threads = new Thread[crawlerContext.getNumOfThread()]; for (int i = 0; i < crawlerContext.getNumOfThread(); i++) { final CrawlerThread crawlerThread = crawlerContainer.getComponent("crawlerThread"); crawlerThread.setCrawlerContext(crawlerContext); crawlerThread.setClientFactory(clientFactory); threads[i] =
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 7.9K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ExecutorFactory.java
* @param displayName The display name for this executor. Used for thread names, logging and error message. * @param corePoolSize The number of threads to keep in the pool * @param maximumPoolSize The maximum number of threads allowed * @param keepAliveTime when the number of threads is greater than * the core, this is the maximum time that excess idle threads * will wait for new tasks before terminating.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 3.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null; } }; Callables.threadRenaming(callable, newName).call(); assertEquals(oldName, Thread.currentThread().getName()); } @J2ktIncompatible @GwtIncompatible // threads public void testRenaming_exceptionalReturn() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.4K bytes - Viewed (0)