Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 465 for thread (0.04 seconds)

  1. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

              public void run() {
                taskDone = true;
              }
            };
        ScheduledFuture<?> future =
            TestingExecutors.noOpScheduledExecutor().schedule(task, 10, MILLISECONDS);
        Thread.sleep(20);
        assertFalse(taskDone);
        assertFalse(future.isDone());
      }
    
      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Oct 18 22:10:29 GMT 2024
    - 3.7K bytes
    - Click Count (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/ClingSupport.java

        /**
         * Ctor that creates "managed" ClassWorld. This constructor is not used in "normal" circumstances.
         */
        public ClingSupport() {
            this(new ClassWorld(CORE_CLASS_REALM_ID, Thread.currentThread().getContextClassLoader()), true);
        }
    
        /**
         * Ctor to be used when running in ClassWorlds Launcher.
         */
        public ClingSupport(ClassWorld classWorld) {
            this(classWorld, false);
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Feb 08 16:25:25 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  3. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

              public void run() {
                taskDone = true;
              }
            };
        ScheduledFuture<?> future =
            TestingExecutors.noOpScheduledExecutor().schedule(task, 10, MILLISECONDS);
        Thread.sleep(20);
        assertFalse(taskDone);
        assertFalse(future.isDone());
      }
    
      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Oct 18 22:10:29 GMT 2024
    - 3.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionError.java

     * possibly run in another thread. That cause should itself be an {@code Error}; if not, use {@code
     * ExecutionException} or {@link UncheckedExecutionException}. This allows the client code to
     * continue to distinguish between exceptions and errors, even when they come from other threads.
     *
     * @author Chris Povirk
     * @since 10.0
     */
    @GwtCompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4K bytes
    - Click Count (0)
  5. guava/src/com/google/common/graph/MapRetrievalCache.java

      // Internal methods (package-visible, but treat as only subclass-visible)
    
      @Override
      @Nullable V getIfCached(@Nullable Object key) {
        V value = super.getIfCached(key);
        if (value != null) {
          return value;
        }
    
        // Store a local reference to the cache entry. If the backing map is immutable, this,
        // in combination with immutable cache entries, will ensure a thread-safe cache.
        CacheEntry<K, V> entry;
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/ForwardingMultiset.java

     * invoke methods, they invoke methods on the {@code ForwardingMultiset}.
     *
     * <p>The {@code standard} methods and any collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Kevin Bourrillion
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        CountDownLatch doneSignal = new CountDownLatch(1);
        Thread thread =
            new Thread(
                () -> {
                  try {
                    cache.get(key, loader);
                  } catch (UncheckedExecutionException | ExecutionException e) {
                    doneSignal.countDown();
                  }
                });
        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 117.5K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        CountDownLatch doneSignal = new CountDownLatch(1);
        Thread thread =
            new Thread(
                () -> {
                  try {
                    cache.get(key, loader);
                  } catch (UncheckedExecutionException | ExecutionException e) {
                    doneSignal.countDown();
                  }
                });
        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 115.9K bytes
    - Click Count (0)
  9. guava/src/com/google/common/util/concurrent/ExecutionError.java

     * possibly run in another thread. That cause should itself be an {@code Error}; if not, use {@code
     * ExecutionException} or {@link UncheckedExecutionException}. This allows the client code to
     * continue to distinguish between exceptions and errors, even when they come from other threads.
     *
     * @author Chris Povirk
     * @since 10.0
     */
    @GwtCompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

      /**
       * Invoked when a call is canceled.
       *
       * Like all methods in this interface, this is invoked on the thread that triggered the event. But
       * while other events occur sequentially; cancels may occur concurrently with other events. For
       * example, thread A may be executing [responseBodyStart] while thread B executes [canceled].
       * Implementations must support such concurrent calls.
       *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
Back to Top