Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 740 for Thread (0.13 sec)

  1. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

     * invoke methods, they invoke methods on the {@code ForwardingBlockingDeque}.
     *
     * <p>The {@code standard} methods are not guaranteed to be thread-safe, even when all of the
     * methods that they depend on are thread-safe.
     *
     * @author Emily Soldal
     * @since 14.0
     * @deprecated This class has moved to {@code com.google.common.util.concurrent}. Please use {@link
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/eventbus/DispatcherTest.java

      }
    
      public void testLegacyAsyncDispatcher() {
        dispatcher = Dispatcher.legacyAsync();
    
        CyclicBarrier barrier = new CyclicBarrier(2);
        CountDownLatch latch = new CountDownLatch(2);
    
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      barrier.await();
                    } catch (Exception e) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java

                    org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null;
                    if (accessTimeout != null) {
                        accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread());
                        accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance()
                                .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
                    }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                        break;
                    }
                    Thread.sleep(50);
                }
                assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus());
                for (int i = 0; i < 100; i++) {
                    if (crawler2.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
                        break;
                    }
                    Thread.sleep(50);
                }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                try {
                    QueryLog queryLog = queryLogReader.read();
                    while (queryLog != null) {
                        if (Thread.currentThread().isInterrupted()) {
                            break;
                        }
                        queryLogs.add(queryLog);
                        queryLog = queryLogReader.read();
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 34.4K bytes
    - Viewed (0)
  6. src/main/resources/fess_message_nl.properties

    errors.invalid_header_for_request_file=Ongeldige headerregel: {0}
    errors.could_not_delete_logged_in_user=Kan ingelogde gebruiker niet verwijderen.
    errors.unauthorized_request=Ongeautoriseerd verzoek.
    errors.failed_to_print_thread_dump=Kan thread-dump niet afdrukken.
    errors.file_is_not_supported={0} wordt niet ondersteund.
    errors.plugin_file_is_not_found={0} niet gevonden.
    errors.failed_to_install_plugin=Kan {0} niet installeren.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 10 04:56:21 UTC 2025
    - 12K bytes
    - Viewed (0)
  7. 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)
  8. src/main/java/jcifs/util/AuthenticationRateLimiter.java

            this.cleanupInterval = cleanupInterval;
    
            // Start cleanup scheduler
            this.cleanupScheduler = Executors.newSingleThreadScheduledExecutor(r -> {
                Thread t = new Thread(r, "AuthRateLimiter-Cleanup");
                t.setDaemon(true);
                return t;
            });
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ForwardingMap.java

     * not consistent with {@code equals}.
     *
     * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Kevin Bourrillion
     * @author Jared Levy
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Aug 06 17:32:30 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  10. build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/support/unsafeLazy.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package org.gradle.kotlin.dsl.internal.sharedruntime.support
    
    
    /**
     * Thread unsafe version of [lazy].
     *
     * @see LazyThreadSafetyMode.NONE
     */
    internal
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Sun Oct 01 11:18:48 UTC 2023
    - 867 bytes
    - Viewed (0)
Back to top