Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for rwmutex (0.04 sec)

  1. guava/src/com/google/common/collect/Synchronized.java

      private Synchronized() {}
    
      static class SynchronizedObject implements Serializable {
        final Object delegate;
        final Object mutex;
    
        SynchronizedObject(Object delegate, @CheckForNull Object mutex) {
          this.delegate = checkNotNull(delegate);
          this.mutex = (mutex == null) ? this : mutex;
        }
    
        Object delegate() {
          return delegate;
        }
    
        // No equals and hashCode; see ForwardingObject for details.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 57.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Synchronized.java

      private Synchronized() {}
    
      static class SynchronizedObject implements Serializable {
        final Object delegate;
        final Object mutex;
    
        SynchronizedObject(Object delegate, @CheckForNull Object mutex) {
          this.delegate = checkNotNull(delegate);
          this.mutex = (mutex == null) ? this : mutex;
        }
    
        Object delegate() {
          return delegate;
        }
    
        // No equals and hashCode; see ForwardingObject for details.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 53.4K bytes
    - Viewed (0)
  3. cmd/iam.go

    	// metrics
    	LastRefreshTimeUnixNano         uint64
    	LastRefreshDurationMilliseconds uint64
    	TotalRefreshSuccesses           uint64
    	TotalRefreshFailures            uint64
    
    	sync.Mutex
    
    	iamRefreshInterval time.Duration
    
    	LDAPConfig   xldap.Config  // only valid if usersSysType is LDAPUsers
    	OpenIDConfig openid.Config // only valid if OpenID is configured
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    		ReadData:         readData,
    		InclFreeVersions: opts.InclFreeVersions,
    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top