Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 614 for threads (0.1 sec)

  1. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/LayeredMavenOptions.java

        public Optional<Boolean> alsoMakeDependents() {
            return returnFirstPresentOrEmpty(MavenOptions::alsoMakeDependents);
        }
    
        @Override
        public Optional<String> threads() {
            return returnFirstPresentOrEmpty(MavenOptions::threads);
        }
    
        @Override
        public Optional<String> builder() {
            return returnFirstPresentOrEmpty(MavenOptions::builder);
        }
    
        @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        assertThat(realTaskRunner.activeQueues()).isNotEmpty()
        Thread.sleep(100)
        val threads = arrayOfNulls<Thread>(Thread.activeCount() * 2)
        Thread.enumerate(threads)
        for (t in threads) {
          if (t != null && t.name == "OkHttp TaskRunner") {
            t.interrupt()
          }
        }
        Thread.sleep(100)
        assertThat(realTaskRunner.activeQueues()).isEmpty()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

              // thread.
              executionList.execute();
              return;
            }
    
            // TODO(lukes): handle RejectedExecutionException
            adapterExecutor.execute(
                () -> {
                  try {
                    /*
                     * Threads from our private pool are never interrupted. Threads from a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  4. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

     *
     * <p>This class supports an optional fairness policy for ordering waiting producer and consumer
     * threads. By default, this ordering is not guaranteed. However, a queue constructed with fairness
     * set to {@code true} grants threads access in FIFO order. Fairness generally decreases throughput
     * but reduces variability and avoids starvation.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/eventbus/AllowConcurrentEvents.java

    import java.lang.annotation.Retention;
    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
    
    /**
     * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus
     * may invoke the event subscriber simultaneously from multiple threads.
     *
     * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 1.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/LoadingCache.java

     * instances is using {@link CacheBuilder}.
     *
     * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed
     * by multiple concurrent threads.
     *
     * <p>When evaluated as a {@link Function}, a cache yields the same result as invoking {@link
     * #getUnchecked}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Aug 06 17:12:03 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          return;
        }
        TimedWaiterThread thread = new TimedWaiterThread(new AbstractFuture<Object>() {}, 2, SECONDS);
        thread.start();
        thread.awaitWaiting();
        Thread.class.getMethod("suspend").invoke(thread);
        // Sleep for enough time to add 1500 milliseconds of overwait to the get() call.
        long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime);
        Thread.sleep(toWaitMillis);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/eventbus/AllowConcurrentEvents.java

    import java.lang.annotation.Retention;
    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
    
    /**
     * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus
     * may invoke the event subscriber simultaneously from multiple threads.
     *
     * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 1.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/hash/BloomFilterTest.java

        List<Thread> threads = new ArrayList<>(numThreads);
        final List<Throwable> exceptions = new ArrayList<>(numThreads);
        for (int i = 0; i < numThreads; i++) {
          Thread thread = new Thread(task);
          thread.setUncaughtExceptionHandler(
              new UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread t, Throwable e) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

              // thread.
              executionList.execute();
              return;
            }
    
            // TODO(lukes): handle RejectedExecutionException
            adapterExecutor.execute(
                () -> {
                  try {
                    /*
                     * Threads from our private pool are never interrupted. Threads from a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
Back to top