Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 29 of 29 for tryLock (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top