- Sort Score
- Result 10 results
- Languages All
Results 431 - 440 of 653 for threads (4.77 sec)
-
guava/src/com/google/common/base/Suppliers.java
public T get() { // Another variant of Double Checked Locking. // // We use two volatile reads. We could reduce this to one by // putting our fields into a holder class, but (at least on x86) // the extra memory consumption and indirection are more // expensive than the extra volatile reads. long nanos = expirationNanos; long now = System.nanoTime(); if (nanos == 0 || now - nanos >= 0) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 16.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/Suggester.java
* <li>{@link #popularWords()}: Creates a new PopularWordsRequestBuilder for querying popular words.</li> * <li>{@link #refresh()}: Refreshes the suggestion indices.</li> * <li>{@link #shutdown()}: Shuts down the thread pool.</li> * <li>{@link #createIndexIfNothing()}: Creates a new index if no index exists.</li> * <li>{@link #createNextIndex()}: Creates a new index and replaces the current update alias with the new index.</li>
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 20.7K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/ingest/IngestFactory.java
// Default constructor } /** * Adds an ingester to the factory. * The ingester is inserted into the collection and the array is re-sorted by priority. * This method is thread-safe. * * @param ingester the ingester to add */ public synchronized void add(final Ingester ingester) { if (logger.isDebugEnabled()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/crawlinginfo/AdminCrawlinginfoAction.java
throwValidationError(messages -> messages.addErrorsCrudCouldNotFindCrudTable(GLOBAL, id), this::asListHtml); return null; }); } /** * Print a thread dump. * @param form The edit form. * @return The HTML response. */ @Execute @Secured({ ROLE }) public HtmlResponse threaddump(final EditForm form) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 11.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
public void finalizeReferent() { finalizeReferentCalled = true; } } /** * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we * know that the background thread has stopped and released its strong reference. */ private WeakReference<ReferenceQueue<Object>> queueReference; @Test public void testThatFinalizerStops() { weaklyReferenceQueue();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 8.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
public void finalizeReferent() { finalizeReferentCalled = true; } } /** * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we * know that the background thread has stopped and released its strong reference. */ private WeakReference<ReferenceQueue<Object>> queueReference; @Test public void testThatFinalizerStops() { weaklyReferenceQueue();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 8.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/AbstractConfigHelper.java
/** * The abstract helper for configuration. * * This class provides a basic framework for managing configurations that can be reloaded. * It includes functionality for updating configurations in a separate thread and controlling the reloading interval. */ public abstract class AbstractConfigHelper { /** * Default constructor. */ public AbstractConfigHelper() { // Default constructor }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 1.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/unit/TestSystemProperties.java
return null; } } private void loadTestProperties() { // Load system.properties from test classpath try (InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("system.properties")) { if (is != null) { Properties props = new Properties(); props.load(is);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 2.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/ExecJobTest.java
CountDownLatch latch = new CountDownLatch(2); Thread t1 = new Thread(() -> { for (int i = 0; i < 100; i++) { execJob.jvmOptions("-Xmx" + i + "m"); } latch.countDown(); }); Thread t2 = new Thread(() -> { for (int i = 0; i < 100; i++) { execJob.jvmOptions("-Xms" + i + "m");
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 24.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
SingletonLaContainerFactory.setExternalContextComponentDefRegister(new GenericExternalContextComponentDefRegister()); SingletonLaContainerFactory.init(); final Thread shutdownCallback = new Thread("ShutdownHook") { @Override public void run() { if (logger.isDebugEnabled()) { logger.debug("Destroying LaContainer..");
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 11K bytes - Viewed (0)