Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for Hockin (0.18 sec)

  1. android/guava/src/com/google/common/util/concurrent/LazyLogger.java

      private volatile @Nullable Logger logger;
    
      LazyLogger(Class<?> ownerOfLogger) {
        this.loggerName = ownerOfLogger.getName();
      }
    
      Logger get() {
        /*
         * We use double-checked locking. We could the try racy single-check idiom, but that would
         * depend on Logger not contain mutable state.
         *
         * We could use Suppliers.memoizingSupplier here, but I micro-optimized to this implementation
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * MoreExecutors#newDirectExecutorService} and subject to the same constraints.
       *
       * <p>Although all tasks are immediately executed in the thread that submitted the task, this
       * {@code ExecutorService} imposes a small locking overhead on each task submission in order to
       * implement shutdown and termination behavior.
       *
       * <p>Because of the nature of single-thread execution, the methods {@code scheduleAtFixedRate}
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        exec.awaitTermination(100, MILLISECONDS);
      }
    
      /**
       * Tests that all listeners complete, even if they were added before or after the future was
       * finishing. Also acts as a concurrency test to make sure the locking is done correctly when a
       * future is finishing so that no listeners can be lost.
       */
      public void testAllListenersCompleteSuccessfully()
          throws InterruptedException, ExecutionException {
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Striped.java

         * for (Lock lock : locks) {
         *   lock.unlock();
         * }
         *
         * If we only held the int[] stripes, translating it on the fly to L's, the original locks might
         * be garbage collected after locking them, ending up in a huge mess.
         */
        @SuppressWarnings("unchecked") // we carefully replaced all keys with their respective L's
        List<L> asStripes = (List<L>) result;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 10 20:55:18 GMT 2023
    - 20.3K bytes
    - Viewed (1)
  5. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * </ul>
       *
       * A specific warning about locking: Code that executes user-supplied tasks, such as {@code
       * 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
    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)
  6. android/guava/src/com/google/common/collect/Ordering.java

          return "Ordering.arbitrary()";
        }
    
        /*
         * We need to be able to mock identityHashCode() calls for tests, because it
         * can take 1-10 seconds to find colliding objects. Mocking frameworks that
         * can do magic to mock static method calls still can't do so for a system
         * class, so we need the indirection. In production, Hotspot should still
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 24 19:38:27 GMT 2024
    - 39.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        // way for it to return a false negative would be for the target value to jump around in the map
        // such that none of the subsequent iterations observed it, despite the fact that at every point
        // in time it was present somewhere int the map. This becomes increasingly unlikely as
        // CONTAINS_VALUE_RETRIES increases, though without locking it is theoretically possible.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 91.9K bytes
    - Viewed (0)
  8. guava/src/com/google/common/cache/CacheBuilder.java

       * uncommon to specify {@code concurrencyLevel(1)} in order to achieve more deterministic eviction
       * behavior.
       *
       * <p>Note that future implementations may abandon segment locking in favor of more advanced
       * concurrency controls.
       *
       * @return this {@code CacheBuilder} instance (for chaining)
       * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 51.3K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbFile.java

                    // this is so damn unreliable, needs another race-prone query if required
                    haveAttributes = false;
    
                    // This seems to be the only way to obtain a reliable (with respect to locking) file size here
                    // It is more critical than other attributes because append mode depends on it.
                    // We do only really care if we open for writing and not shared for writing
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Mon Mar 13 12:00:57 GMT 2023
    - 81.6K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        /*
         * TODO(cpovirk): move ForwardingTestCase somewhere common, and use it to
         * test the forwarded methods
         */
      }
    
      @AndroidIncompatible // Mocking ExecutorService is forbidden there. TODO(b/218700094): Don't mock.
      public void testListeningDecorator_noWrapExecuteTask() {
        ExecutorService delegate = mock(ExecutorService.class);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (3)
Back to top