Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 102 for wlock (0.02 seconds)

  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. 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)
  5. 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)
  6. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        final Lock lock;
    
        LockingThread(Lock lock) {
          this.lock = lock;
        }
    
        @Override
        public void run() {
          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        final Lock lock;
    
        LockingThread(Lock lock) {
          this.lock = lock;
        }
    
        @Override
        public void run() {
          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.SmallLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.SmallLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  10. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/util/KotlinSourceParser.kt

            get() = PrintingMessageCollector(System.out, MessageRenderer.PLAIN_RELATIVE_PATHS, false)
    
        fun <T : Any> mapParsedKotlinFiles(vararg sourceRoots: File, block: (KtFile) -> T): List<T> =
            withParsedKotlinSource(sourceRoots.toList()) { ktFiles ->
                ktFiles.map(block)
            }
    
        fun parseSourceRoots(sourceRoots: List<File>, compilationClasspath: List<File>): ParsedKotlinFiles =
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Mar 18 05:37:07 GMT 2026
    - 3.9K bytes
    - Click Count (0)
Back to Top