Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 233 for threads (0.18 sec)

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

                        throw new IllegalArgumentException("Invalid threads core multiplier value: '" + threadConfiguration
                                + "'. Value must be positive.");
                    }
    
                    int procs = Runtime.getRuntime().availableProcessors();
                    int threads = (int) (coreMultiplier * procs);
                    return threads == 0 ? 1 : threads;
                } else {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

        // Thread#setPriority() already checks for validity. These error messages
        // are nicer though and will fail-fast.
        checkArgument(
            priority >= Thread.MIN_PRIORITY,
            "Thread priority (%s) must be >= %s",
            priority,
            Thread.MIN_PRIORITY);
        checkArgument(
            priority <= Thread.MAX_PRIORITY,
            "Thread priority (%s) must be <= %s",
            priority,
            Thread.MAX_PRIORITY);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:50:54 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. 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.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Oct 03 16:03:55 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/base/SuppliersTest.java

        for (int i = 0; i < numThreads; i++) {
          threads[i] =
              new Thread() {
                @Override
                public void run() {
                  assertSame(Boolean.TRUE, memoizedSupplier.get());
                }
              };
        }
        for (Thread t : threads) {
          t.start();
        }
        for (Thread t : threads) {
          t.join();
        }
    
        if (thrown.get() != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/base/SuppliersTest.java

        for (int i = 0; i < numThreads; i++) {
          threads[i] =
              new Thread() {
                @Override
                public void run() {
                  assertSame(Boolean.TRUE, memoizedSupplier.get());
                }
              };
        }
        for (Thread t : threads) {
          t.start();
        }
        for (Thread t : threads) {
          t.join();
        }
    
        if (thrown.get() != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/MoreExecutors.java

      }
    
      /**
       * Add a shutdown hook to wait for thread completion in the given {@link ExecutorService service}.
       * This is useful if the given service uses daemon threads, and we want to keep the JVM from
       * exiting immediately on shutdown, instead giving these daemon threads a chance to terminate
       * normally.
       *
       * @param service ExecutorService which uses daemon threads
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

              public @Nullable Void call() throws Exception {
                assertEquals(Thread.currentThread().getName(), newName.get());
                return null;
              }
            };
        Callables.threadRenaming(callable, newName).call();
        assertEquals(oldName, Thread.currentThread().getName());
      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testRenaming_exceptionalReturn() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  8. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

                        throw new IllegalArgumentException("Invalid threads core multiplier value: '" + threadConfiguration
                                + "'. Value must be positive.");
                    }
    
                    int procs = Runtime.getRuntime().availableProcessors();
                    int threads = (int) (coreMultiplier * procs);
                    return threads == 0 ? 1 : threads;
                } else {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      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
       * fails.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        start();
      }
    
      // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
      // may put a thread into an uninterruptible operation intentionally, so there is no other way to
      // clean up these threads.
      @SuppressWarnings("deprecation")
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
Back to top