Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 33 for tryLock (0.15 sec)

  1. 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)
  2. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/ParallelDownloadsIntegrationTest.groovy

                    compile 'test:test3:1.0'
                    compile 'test:test4:1.0'
    
                    components {
                        all { ComponentMetadataDetails details ->
                            if (!lock.tryLock()) {
                                throw new AssertionError("Rule called concurrently")
                            }
                            lock.unlock()
                        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 17:10:15 UTC 2024
    - 13K bytes
    - Viewed (0)
  3. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java

    import java.util.concurrent.atomic.AtomicReference;
    
    import static org.gradle.internal.resources.DefaultResourceLockCoordinationService.lock;
    import static org.gradle.internal.resources.DefaultResourceLockCoordinationService.tryLock;
    import static org.gradle.internal.resources.DefaultResourceLockCoordinationService.unlock;
    
    @ServiceScope(Scope.CrossBuildSession.class)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 09 04:43:28 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

                    acquiredAggregatorLock = aggregator ? aggregatorLock.writeLock() : aggregatorLock.readLock();
                    acquiredProjectLock = getProjectLock(session);
                    if (!acquiredAggregatorLock.tryLock()) {
                        Thread owner = aggregatorLock.getOwner();
                        MojoDescriptor ownerMojo = owner != null ? mojos.get(owner) : null;
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Feb 28 23:31:09 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer.go

    // TryRead read up to len(p) bytes into p like Read but it is not blocking.
    // If it has not succeeded to acquire the lock, it return 0 as n and ErrAcquireLock.
    func (r *RingBuffer) TryRead(p []byte) (n int, err error) {
    	ok := r.mu.TryLock()
    	if !ok {
    		return 0, ErrAcquireLock
    	}
    	defer r.mu.Unlock()
    	if err := r.readErr(true); err != nil {
    		return 0, err
    	}
    	if len(p) == 0 {
    		return 0, r.readErr(true)
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. 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)
  7. pkg/kubelet/cm/dra/claiminfo_test.go

    				return func() error {
    					if cache.RWMutex.TryLock() {
    						return errors.New("Lock succeeded")
    					}
    					return nil
    				}
    			},
    		},
    		{
    			description: "cache is Rlocked inside a function",
    			funcGen: func(cache *claimInfoCache) func() error {
    				return func() error {
    					if cache.RWMutex.TryRLock() {
    						return errors.New("RLock succeeded")
    					}
    					return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:31 UTC 2024
    - 21K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top