Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 128 for Flock (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/lru/lru.go

    	c.mu.Lock()
    	bucketIdx := c.nextCleanupBucket
    	timeToExpire := time.Until(c.buckets[bucketIdx].newestEntry)
    	// wait for newest entry to expire before cleanup without holding lock
    	if timeToExpire > 0 {
    		c.mu.Unlock()
    		time.Sleep(timeToExpire)
    		c.mu.Lock()
    	}
    	for _, ent := range c.buckets[bucketIdx].entries {
    		c.removeElement(ent)
    	}
    	c.nextCleanupBucket = (c.nextCleanupBucket + 1) % numBuckets
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  4. src/main/webapp/WEB-INF/orig/view/login/newpassword.jsp

    						<div class="input-group-append">
    							<span class="input-group-text">
    								<i class="fa fa-lock fa-fw" aria-hidden="true"></i>
    							</span>
    						</div>
    					</div>
    					<div class="text-center">
    						<button type="submit" name="changePassword"
    							class="btn btn-primary btn-block"
    							value="<la:message key="labels.login.update"/>">
    							<i class="fa fa-pencil-alt" aria-hidden="true"></i>
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Feb 23 08:03:44 GMT 2026
    - 3.1K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

      private final Object lock = new Object();
    
      /**
       * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
       * RunnableExecutorPair#next} field.
       */
      @GuardedBy("lock")
      private @Nullable RunnableExecutorPair runnables;
    
      @GuardedBy("lock")
      private boolean executed;
    
      /** Creates a new, empty {@link ExecutionList}. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  6. src/main/webapp/WEB-INF/orig/view/login/index.jsp

    						<div class="input-group-append">
    							<span class="input-group-text">
    								<i class="fa fa-lock fa-fw" aria-hidden="true"></i>
    							</span>
    						</div>
    					</div>
    					<div class="text-center">
    						<button type="submit" name="login"
    							class="btn btn-primary btn-block"
    							value="<la:message key="labels.login"/>">
    							<i class="fa fa-sign-in" aria-hidden="true"></i>
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Feb 23 08:03:44 GMT 2026
    - 3K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

                      : t;
              releaseShared(finalState);
            } else if (getState() == COMPLETING) {
              // If some other thread is currently completing the future, block until
              // they are done so we can guarantee completion.
              acquireShared(-1);
            }
            return doCompletion;
          }
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

                      : t;
              releaseShared(finalState);
            } else if (getState() == COMPLETING) {
              // If some other thread is currently completing the future, block until
              // they are done so we can guarantee completion.
              acquireShared(-1);
            }
            return doCompletion;
          }
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

       *
       * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST);
       *
       * lockA.lock();
       *
       * lockB.lock(); // will throw an IllegalStateException
       * lockC.lock(); // will throw an IllegalStateException
       *
       * lockA.lock(); // reentrant acquisition is okay
       * }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        static TestCondition create() {
          Lock lock = new ReentrantLock();
          Condition condition = lock.newCondition();
          return new TestCondition(lock, condition);
        }
    
        @Override
        public void await() throws InterruptedException {
          lock.lock();
          try {
            condition.await();
          } finally {
            lock.unlock();
          }
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
Back to Top