- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 67 for tryLock (0.24 sec)
-
subprojects/composite-builds/src/test/groovy/org/gradle/composite/internal/DefaultIncludedBuildTaskGraphParallelTest.groovy
_ * project.services >> projectServices _ * project.pluginManager >> Stub(PluginManagerInternal) def lock = Stub(ResourceLock) _ * projectState.taskExecutionLock >> lock _ * lock.tryLock() >> true return task } private BuildWorkGraphController buildWorkGraphController(String displayName, BuildServices services) { def builder = Mock(BuildLifecycleController.WorkGraphBuilder)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 20.6K bytes - Viewed (0) -
internal/grid/muxclient.go
gridLogIf(m.ctx, err) m.closeLocked() return false } } func (m *muxClient) close() { if debugPrint { fmt.Println("closing outgoing mux", m.MuxID) } if !m.respMu.TryLock() { // Cancel before locking - will unblock any pending sends. if m.cancelFn != nil { m.cancelFn(context.Canceled) } // Wait for senders to release. m.respMu.Lock() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
assertTrue(signaledBeforeTimeout); assertTimeNotPassed(stopwatch, LONG_DELAY_MS); assertInterrupted(); } // Lock.tryLock() tests public void testTryLockTimeoutExceeded() { Stopwatch stopwatch = Stopwatch.createStarted(); Lock lock = new ReentrantLock(); Thread lockThread = acquireFor(lock, 5, SECONDS);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
assertTrue(signaledBeforeTimeout); assertTimeNotPassed(stopwatch, LONG_DELAY_MS); assertInterrupted(); } // Lock.tryLock() tests public void testTryLockTimeoutExceeded() { Stopwatch stopwatch = Stopwatch.createStarted(); Lock lock = new ReentrantLock(); Thread lockThread = acquireFor(lock, 5, SECONDS);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 30.9K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
} } // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { drainReferenceQueues(); } finally { unlock(); } } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 143.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/MapMakerInternalMap.java
} // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { maybeDrainReferenceQueues(); } finally { unlock(); } } } @GuardedBy("this")
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
} } // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { drainReferenceQueues(); } finally { unlock(); } } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 149.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
} // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { maybeDrainReferenceQueues(); } finally { unlock(); } } } @GuardedBy("this")
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/testFixtures/kotlin/org/gradle/kotlin/dsl/fixtures/bytecode/AsmExtensions.kt
} internal inline fun <reified T> MethodVisitor.TRY_CATCH( noinline tryBlock: MethodVisitor.() -> Unit, noinline catchBlock: MethodVisitor.() -> Unit ) = TRY_CATCH(T::class.internalName, tryBlock, catchBlock) internal fun MethodVisitor.TRY_CATCH( exceptionType: InternalName, tryBlock: MethodVisitor.() -> Unit, catchBlock: MethodVisitor.() -> Unit ) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
} func (rt *requestTracker) trackParallelRequests() { if !rt.shouldTrackParallelRequests { // do not track parallel requests unless specifically enabled return } if rt.parallelLock.TryLock() { // lock acquired: we are the only or the first concurrent request // initialize the next set of parallel requests rt.parallelRequests = 1 } else { // lock is held by other requests
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)