- Sort Score
- Result 10 results
- Languages All
Results 21 - 29 of 29 for tryLock (0.17 sec)
-
platforms/core-runtime/files/src/main/java/org/gradle/internal/file/locking/ExclusiveFileAccessManager.java
while (lock == null && getTimeMillis() < expiry) { randomAccessFile = new RandomAccessFile(lockFile, "rw"); channel = randomAccessFile.getChannel(); lock = channel.tryLock(); if (lock == null) { maybeCloseQuietly(channel); maybeCloseQuietly(randomAccessFile); Thread.sleep(pollIntervalMs); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jan 10 15:52:53 UTC 2024 - 3.2K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/work/TestWorkerLeaseService.groovy
return false } @Override boolean isLockedByCurrentThread() { return false } @Override boolean tryLock() { return false } @Override void unlock() { } @Override String getDisplayName() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
internal/cachevalue/cache.go
return *v, nil } // Fetch new value asynchronously, while we do not return an error // if v != nil value or if t.opts.NoWait && v != nil && tNow-vTime < ttl.Milliseconds()*2 { if t.updating.TryLock() { go func() { defer t.updating.Unlock() t.update(context.Background()) }() } return *v, nil } // Get lock. Either we get it or we wait for it. t.updating.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/AbstractExecutionPlanSpec.groovy
} @Override boolean isLockedByCurrentThread() { return locked && Thread.currentThread() == owner } @Override boolean tryLock() { if (!locks.contains(this) && locked) { return false } locked = true locks.add(this) return true }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 24 11:56:02 UTC 2023 - 7.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() { for (Striped<?> striped : strongImplementations()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() { for (Striped<?> striped : strongImplementations()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.4K 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) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/support/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 - 8.5K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_mipsx.s
TEXT ·Oruintptr(SB), NOSPLIT, $0-12 JMP ·Or32(SB) TEXT ·spinLock(SB),NOSPLIT,$0-4 MOVW state+0(FP), R1 MOVW $1, R2 SYNC try_lock: MOVW R2, R3 check_again: LL (R1), R4 BNE R4, check_again SC R3, (R1) BEQ R3, try_lock SYNC RET TEXT ·spinUnlock(SB),NOSPLIT,$0-4 MOVW state+0(FP), R1 SYNC MOVW R0, (R1) SYNC
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 21:29:34 UTC 2024 - 4.9K bytes - Viewed (0)