Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 614 for threads (0.09 sec)

  1. src/main/java/jcifs/smb1/smb1/TestLocking.java

                } else {
                    t.url = args[ai];
                }
            }
    
            Thread[] threads = new Thread[t.numThreads];
            int ti;
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti] = new Thread(t);
                System.out.print(threads[ti].getName());
                threads[ti].start();
            }
    
            while (t.numComplete < t.numThreads) {
                long delay;
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 3.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. docs/contribute/concurrency.md

    #### Do-stuff-later pool
    
    Sometimes there's an action required like calling the application layer or responding to a ping, and the thread discovering the action is not the thread that should do the work. We enqueue a runnable on this executor and it gets handled by one of the executor's threads.
    
    ### Locks
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java

                });
            }
    
            for (Thread th : threads) {
                th.start();
            }
            for (Thread th : threads) {
                th.join();
            }
            assertEquals(num, count.get());
            assertEquals(num, valueSet.size());
    
            Set<String> valueSet2 = Collections.synchronizedSet(new HashSet<>());
            threads = new Thread[threadNum];
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

            final Thread[] threads = new Thread[crawlerContext.getNumOfThread()];
            for (int i = 0; i < crawlerContext.getNumOfThread(); i++) {
                final CrawlerThread crawlerThread = crawlerContainer.getComponent("crawlerThread");
                crawlerThread.setCrawlerContext(crawlerContext);
                crawlerThread.setClientFactory(clientFactory);
                threads[i] =
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

      /**
       * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we
       * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until
       * the already-requested ones are in service, otherwise we might create more threads than we need.
       *
       * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top