Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 638 for threadId (0.41 sec)

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

                } else {
                    t.url = args[ai];
                }
            }
    
            final Thread[] threads = new Thread[t.numThreads];
            int ti;
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti] = new Thread(t);
                logger.info(threads[ti].getName());
                threads[ti].start();
            }
    
            while (t.numComplete < t.numThreads) {
                long delay;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  2. 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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessTimeResourceProviderTest.java

            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // Check all providers were created successfully
            for (int i = 0; i < threadCount; i++) {
                assertNull("Thread " + i + " threw exception", exceptions[i]);
                assertNotNull("Thread " + i + " failed to create provider", providers[i]);
            }
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/RequestWithFileIdTest.java

                threads[i] = new Thread(() -> {
                    byte[] threadFileId = new byte[16];
                    Arrays.fill(threadFileId, (byte) index);
                    request.setFileId(threadFileId);
                });
                threads[i].start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java

            // Verify that thread dump was processed
            assertFalse("Should capture some thread dump output", capturedOutput.isEmpty());
    
            // Verify format - should contain "Thread:" entries
            boolean hasThreadEntry = capturedOutput.stream().anyMatch(line -> line.startsWith("Thread:"));
            assertTrue("Should contain Thread: entries", hasThreadEntry);
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        thread1.callAndAssertReturns(enter());
        thread2.callAndAssertBlocks(enter());
        thread1.callAndAssertReturns(leave());
        thread2.assertPriorCallReturns(enter());
      }
    
      public final void testTryEnter() throws Exception {
        thread1.callAndAssertReturns(true, tryEnter());
        thread2.callAndAssertReturns(false, tryEnter());
        thread1.callAndAssertReturns(true, tryEnter());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb2/Smb2EchoRequestTest.java

            @DisplayName("Should maintain thread safety")
            void testThreadSafety() throws InterruptedException {
                int threadCount = 10;
                Thread[] threads = new Thread[threadCount];
                boolean[] success = new boolean[threadCount];
    
                for (int i = 0; i < threadCount; i++) {
                    final int index = i;
                    threads[i] = new Thread(() -> {
                        try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *   <li>a {@linkplain ThreadFactoryBuilder#setNameFormat naming format}
     *   <li>a {@linkplain Thread#setPriority thread priority}
     *   <li>an {@linkplain Thread#setUncaughtExceptionHandler uncaught exception handler}
     *   <li>a {@linkplain ThreadFactory#newThread backing thread factory}
     * </ul>
     *
     * <p>If no backing thread factory is provided, a default backing thread factory is used as if by
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:35:26 UTC 2025
    - 9K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

        }
    
        /**
         * Checks if the crawler threads are daemon threads.
         * @return true if daemon threads, false otherwise.
         */
        public boolean isDaemon() {
            return daemon;
        }
    
        /**
         * Sets whether the crawler threads should be daemon threads.
         * @param daemon true to make threads daemon, false otherwise.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java

     * <p>
     * The context includes information such as the session ID, active thread count, access count, crawler status,
     * URL filter, rule manager, interval controller, robots.txt URL set, sitemaps, number of threads,
     * maximum thread check count, maximum depth, and maximum access count.
     * </p>
     *
     * <p>
     * It also provides thread-local storage for sitemaps, allowing each thread to have its own set of sitemaps.
     * </p>
     */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.9K bytes
    - Viewed (0)
Back to top