- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,285 for threaded (0.12 sec)
-
pkg/controller/garbagecollector/graph_builder.go
// the in-memory graph according to the changes. graphChanges workqueue.TypedRateLimitingInterface[*event] // uidToNode doesn't require a lock to protect, because only the // single-threaded GraphBuilder.processGraphChanges() reads/writes it. uidToNode *concurrentUIDToNode // GraphBuilder is the producer of attemptToDelete and attemptToOrphan, GC is the consumer.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
*/ public boolean hasQueuedThread(Thread thread) { return lock.hasQueuedThread(thread); } /** * Queries whether any threads are waiting for the given guard to become satisfied. Note that * because timeouts and interrupts may occur at any time, a {@code true} return does not guarantee * that the guard becoming satisfied in the future will awaken any threads. This method is
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K 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) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
*/ public boolean hasQueuedThread(Thread thread) { return lock.hasQueuedThread(thread); } /** * Queries whether any threads are waiting for the given guard to become satisfied. Note that * because timeouts and interrupts may occur at any time, a {@code true} return does not guarantee * that the guard becoming satisfied in the future will awaken any threads. This method is
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
assertFalse(completed); thread.start(); thread.join(); assertTrue(completed); // Creating a new thread from the same ThreadFactory will have the same // pool ID but a thread ID of 2. Thread thread2 = threadFactory.newThread(monitoredRunnable); checkThreadPoolName(thread2, 2); assertEquals(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tf_passes.td
// Func, Stablehlo, Shape, and Quantization. // // If we do not register them here, an error will be // triggered because we cannot load a dialect while in a // multi-threaded execution context, and PassManager is // multi-threaded. let dependentDialects = [ "chlo::ChloDialect", "mhlo::MhloDialect", "shape::ShapeDialect", "stablehlo::StablehloDialect", "vhlo::VhloDialect",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:18:05 UTC 2024 - 99.6K 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) -
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
assertFalse(completed); thread.start(); thread.join(); assertTrue(completed); // Creating a new thread from the same ThreadFactory will have the same // pool ID but a thread ID of 2. Thread thread2 = threadFactory.newThread(monitoredRunnable); checkThreadPoolName(thread2, 2); assertEquals(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/project/DefaultProjectStateRegistryTest.groovy
thread.block() instant.thread1 } } workerThread { thread.blockUntil.start state.applyToMutableState { instant.thread2 } } } then: instant.thread2 > instant.thread1 }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 24.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* * Our solution is for threads to CAS seenExceptions from null to a Set populated with _the * initial exception_, no matter which thread does the work. This ensures that seenExceptions * always contains not just the current thread's exception but also the initial thread's. */ Set<Throwable> seenExceptionsLocal = seenExceptions;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0)