Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 129 for acquirem (0.12 sec)

  1. guava/src/com/google/common/util/concurrent/RateLimiter.java

       */
      @CanIgnoreReturnValue
      public double acquire() {
        return acquire(1);
      }
    
      /**
       * Acquires the given number of permits from this {@code RateLimiter}, blocking until the request
       * can be granted. Tells the amount of time slept, if any.
       *
       * @param permits the number of permits to acquire
       * @return time spent sleeping to enforce rate, in seconds; 0.0 if not rate-limited
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       */
      @CanIgnoreReturnValue
      public double acquire() {
        return acquire(1);
      }
    
      /**
       * Acquires the given number of permits from this {@code RateLimiter}, blocking until the request
       * can be granted. Tells the amount of time slept, if any.
       *
       * @param permits the number of permits to acquire
       * @return time spent sleeping to enforce rate, in seconds; 0.0 if not rate-limited
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

     *
     * <p>Deadlocks can arise when locks are acquired in an order that forms a cycle. In a simple
     * example involving two locks and two threads, deadlock occurs when one thread acquires Lock A, and
     * then Lock B, while another thread acquires Lock B, and then Lock A:
     *
     * <pre>
     * Thread1: acquire(LockA) --X acquire(LockB)
     * Thread2: acquire(LockB) --X acquire(LockA)
     * </pre>
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  4. internal/dsync/drwmutex.go

    	quorumLocked := checkQuorumLocked(locks, quorum) && locksFailed <= tolerance
    	if !quorumLocked {
    		log("dsync: Unable to acquire lock in quorum %#v\n", args)
    		// Release all acquired locks without quorum.
    		if !releaseAll(ctx, ds, tolerance, owner, locks, isReadLock, restClnts, names...) {
    			log("Unable to release acquired locks, these locks will expire automatically %#v\n", args)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  5. internal/lsync/lrwmutex_test.go

    	lrwm := NewLRWMutex()
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("2nd read lock acquired, waiting...")
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.RUnlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTreeImpl.java

         */
        public SmbTreeImpl acquire ( boolean track ) {
            long usage = this.usageCount.incrementAndGet();
            if ( log.isTraceEnabled() ) {
                log.trace("Acquire tree " + usage + " " + this);
            }
    
            if ( track && this.traceResource ) {
                synchronized ( this.acquires ) {
                    this.acquires.add(truncateTrace(Thread.currentThread().getStackTrace()));
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 29.6K bytes
    - Viewed (0)
  7. cmd/lock-rest-server.go

    }
    
    // LockHandler - Acquires a lock.
    func (l *lockRESTServer) LockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCLock.NewResponse()
    	success, err := l.ll.Lock(context.Background(), *args)
    	if err == nil && !success {
    		return l.makeResp(resp, errLockConflict)
    	}
    	return l.makeResp(resp, err)
    }
    
    // UnlockHandler - releases the acquired lock.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. internal/dsync/drwmutex_test.go

    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	drwm2 := NewDRWMutex(ds, "simplelock")
    	ctx2, cancel2 := context.WithCancel(context.Background())
    	if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("2nd read lock acquired, waiting...")
    
    	go func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        }
      }
    
      fun connectionCount(): Int {
        return connections.size
      }
    
      /**
       * Attempts to acquire a recycled connection to [address] for [connectionUser]. Returns the connection if it
       * was acquired, or null if no connection was acquired. The acquired connection will also be
       * given to [connectionUser] who may (for example) assign it to a [RealCall.connection].
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. docs/en/docs/deployment/https.md

    * For HTTPS, **the server** needs to **have "certificates"** generated by a **third party**.
        * Those certificates are actually **acquired** from the third party, not "generated".
    * Certificates have a **lifetime**.
        * They **expire**.
        * And then they need to be **renewed**, **acquired again** from the third party.
    * The encryption of the connection happens at the **TCP level**.
        * That's one layer **below HTTP**.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 12K bytes
    - Viewed (0)
Back to top