Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 692 for threadId (0.03 sec)

  1. src/main/java/org/codelibs/core/collection/LruHashMap.java

     * <p>
     * <strong>Thread-Safety:</strong> This class is <strong>NOT thread-safe</strong>.
     * It extends {@link LinkedHashMap} without synchronization. If multiple threads access
     * an instance concurrently, and at least one thread modifies the map structurally,
     * it must be synchronized externally.
     * </p>
     * <p>
     * For thread-safe usage, wrap with {@link java.util.Collections#synchronizedMap(Map)}:
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat Nov 22 11:21:59 UTC 2025
    - 3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                });
        assertFalse(task.isDone());
        Thread thread =
            new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      task.run();
                    } finally {
                      exitLatch.countDown();
                    }
                  }
                });
        thread.start();
        enterLatch.await();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/storage/HandlerTest.java

                    }
                }).start();
            }
    
            // Signal all threads to start at once
            startLatch.countDown();
    
            // Wait for all threads to complete
            assertTrue("Threads did not complete in time", doneLatch.await(5, TimeUnit.SECONDS));
    
            // All threads should fail with the same IOException (endpoint is blank)
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                  @Override
                  public Integer call() {
                    return Thread.currentThread().getStackTrace().length;
                  }
                },
                directExecutor());
        settableFuture.set(null);
        assertThat(getDone(stackDepthCheck))
            .isLessThan(Thread.currentThread().getStackTrace().length + 100);
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

      /**
       * Returns an exception handler that exits the system. This is particularly useful for the main
       * thread, which may start up other, non-daemon threads, but fail to fully initialize the
       * application successfully.
       *
       * <p>Example usage:
       *
       * <pre>
       * public static void main(String[] args) {
       *   Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());
       *   ...
       * </pre>
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Feb 10 21:03:40 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
        new Thread(
                () -> {
                  assertThrows(CancellationException.class, future::get);
                  successLatch.countDown();
                })
            .start();
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/base/internal/Finalizer.java

            logger.log(
                Level.INFO, "Failed to create a thread without inherited thread-local values", t);
          }
        }
        if (thread == null) {
          thread = new Thread((ThreadGroup) null, finalizer, threadName);
        }
        thread.setDaemon(true);
    
        try {
          if (inheritableThreadLocals != null) {
            inheritableThreadLocals.set(thread, null);
          }
        } catch (Throwable t) {
          logger.log(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

                return jvmGcObj;
            }).toArray(n -> new JvmGcObj[n]);
            final Threads threads = jvmStats.getThreads();
            final JvmThreadsObj jvmThreadsObj = new JvmThreadsObj();
            jvmObj.threads = jvmThreadsObj;
            jvmThreadsObj.count = threads.getCount();
            jvmThreadsObj.peak = threads.getPeakCount();
            final Classes classes = jvmStats.getClasses();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
        new Thread(
                () -> {
                  assertThrows(CancellationException.class, future::get);
                  successLatch.countDown();
                })
            .start();
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

                    }
                  });
          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 91.1K bytes
    - Viewed (0)
Back to top