Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 47 for mock (0.17 sec)

  1. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

    import static java.util.Arrays.asList;
    import static org.junit.Assert.assertThrows;
    import static org.mockito.ArgumentMatchers.isA;
    import static org.mockito.Mockito.eq;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.when;
    
    import com.google.common.base.Equivalence;
    import com.google.common.collect.testing.features.CollectionFeature;
    import com.google.common.collect.testing.features.CollectionSize;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 14.2K bytes
    - Viewed (0)
  2. 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, TimeUnit.MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.1K bytes
    - Viewed (0)
  3. 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
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * ListenableFuture} listeners, should take care not to do so while holding a lock. Additionally,
       * as a further line of defense, prefer not to perform any locking inside a task that will be run
       * under {@code directExecutor}: Not only might the wait for a lock be long, but if the running
       * thread was holding a lock, the listener may deadlock or break lock isolation.
       *
       * <p>This instance is equivalent to:
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          }
        }
      }
    
      /**
       * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)}
       * uninterruptibly.
       *
       * @since 30.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit) {
        boolean interrupted = false;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 14.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

      /**
       * Interrupts the running task. Because this internally calls {@link Thread#interrupt()} which can
       * in turn invoke arbitrary code it is not safe to call while holding a lock.
       */
      final void interruptTask() {
        // Since the Thread is replaced by DONE before run() invokes listeners or returns, if we succeed
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Sep 29 21:34:48 GMT 2023
    - 9.9K bytes
    - Viewed (0)
  8. guava/src/com/google/common/cache/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

       * value, you should always choose it explicitly.
       *
       * <p>The current implementation uses the concurrency level to create a fixed number of hashtable
       * segments, each governed by its own write lock. The segment lock is taken once for each explicit
       * write, and twice for each cache loading computation (once prior to loading the new value, and
       * once after loading completes). Much internal cache management is performed at the segment
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  10. android/guava-testlib/test/com/google/common/collect/testing/IteratorTesterTest.java

    import java.util.List;
    import java.util.NoSuchElementException;
    import junit.framework.AssertionFailedError;
    import junit.framework.TestCase;
    
    /**
     * Unit test for IteratorTester.
     *
     * @author Mick Killianey
     */
    @GwtCompatible
    @SuppressWarnings("serial") // No serialization is used in this test
    public class IteratorTesterTest extends TestCase {
    
      public void testCanCatchDifferentLengthOfIteration() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 12:41:04 GMT 2023
    - 10.4K bytes
    - Viewed (0)
Back to top