Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 973 for Threads (0.13 seconds)

  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
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  2. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java

        @Nonnull
        Optional<Boolean> alsoMakeDependents();
    
        /**
         * Returns the number of threads used for parallel builds.
         *
         * @return an {@link Optional} containing the number of threads (or "1C" for one thread per CPU core), or empty if not specified
         */
        @Nonnull
        Optional<String> threads();
    
        /**
         * Returns the id of the build strategy to use.
         *
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 8K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      /** Returns a new started daemon Thread running the given runnable. */
      final Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
       * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testSubmitAsync_asyncCallable_returnsInterruptedFuture() throws InterruptedException {
        assertThat(Thread.interrupted()).isFalse();
        SettableFuture<Integer> cancelledFuture = SettableFuture.create();
        cancelledFuture.cancel(true);
        assertThat(Thread.interrupted()).isFalse();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testSubmitAsync_asyncCallable_returnsInterruptedFuture() throws InterruptedException {
        assertThat(Thread.interrupted()).isFalse();
        SettableFuture<Integer> cancelledFuture = SettableFuture.create();
        cancelledFuture.cancel(true);
        assertThat(Thread.interrupted()).isFalse();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/CommonsCliMavenOptions.java

                return Optional.of(Boolean.TRUE);
            }
            return Optional.empty();
        }
    
        @Override
        public Optional<String> threads() {
            if (commandLine.hasOption(CLIManager.THREADS)) {
                return Optional.of(commandLine.getOptionValue(CLIManager.THREADS));
            }
            return Optional.empty();
        }
    
        @Override
        public Optional<String> builder() {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Sep 25 17:39:57 GMT 2025
    - 14.8K bytes
    - Click Count (0)
  7. 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}.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 12:40:22 GMT 2026
    - 8.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/Monitor.java

       */
      public boolean hasQueuedThread(Thread thread) {
        return lock.hasQueuedThread(thread);
      }
    
      /**
       * Queries whether any threads are waiting for the given guard to become satisfied. Note that
       * because timeouts and interrupts may occur at any time, a {@code true} return does not guarantee
       * that the guard becoming satisfied in the future will awaken any threads. This method is
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
  9. 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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb/PreauthIntegrityTest.java

                        fail("Thread failed: " + e.getMessage());
                    } finally {
                        doneLatch.countDown();
                    }
                });
            }
    
            // Start all threads at once
            startLatch.countDown();
    
            // Wait for completion
            assertTrue(doneLatch.await(5, TimeUnit.SECONDS), "Threads did not complete in time");
            executor.shutdown();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 10.5K bytes
    - Click Count (0)
Back to Top