- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for tryLock (0.1 sec)
-
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
if (workSource.allExecutionComplete()) { // Need to hold a worker lease in order to finish up if (!workerLease.isLockedByCurrentThread()) { if (!workerLease.tryLock()) { return RETRY; } } workSource.collectFailures(failures); queue.removeFinishedPlans(); return FINISHED;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/model/CalculatedValueContainer.java
}); owner.calculationState = null; } finally { releaseLock(); } } private void acquireLock() { if (lock.tryLock()) { // Lock not contended - can proceed return; } // Lock is contended, so release project locks while waiting to acquire the lock
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:26:19 UTC 2024 - 10.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/project/DefaultProjectStateRegistry.java
// It's important that we do not block waiting for the lock while holding the project mutation lock. // Doing so can lead to deadlocks. assertCanMutate(); if (lock.tryLock()) { // Update lock was not contended, can keep holding the project locks return; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 21K bytes - Viewed (0) -
doc/go_mem.html
</p> <p class="rule"> A successful call to <code>l.TryLock</code> (or <code>l.TryRLock</code>) is equivalent to a call to <code>l.Lock</code> (or <code>l.RLock</code>). An unsuccessful call has no synchronizing effect at all. As far as the memory model is concerned, <code>l.TryLock</code> (or <code>l.TryRLock</code>) may be considered to be able to return false even when the mutex <i>l</i> is unlocked.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
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) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirExpressionInfoProvider.kt
// Body and catch blocks of try-catch expressions are used if the try-catch itself // is used. is KtTryExpression -> (parent.tryBlock == child || child in parent.catchClauses) && isUsed(parent) // If expressions always use their condition, and the branches are used if the // If itself is used as an expression.
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Jun 05 16:16:39 UTC 2024 - 17.6K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirExpressionTypeProvider.kt
val tryExpression = expression.unwrapQualified<KtTryExpression> { tryExpression, currentExpression -> currentExpression == tryExpression.tryBlock } ?: return null return getExpectedType(tryExpression) } private fun getExpectedTypeOfElvisOperand(expression: PsiElement): KaType? {
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 24.4K bytes - Viewed (0)