Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 635 for Spread (0.03 sec)

  1. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        assertThat(Thread.interrupted()).isTrue();
      }
    
      public void testInterrupt_doesNotInterruptSubsequentTask() throws Exception {
        // Run a task that interrupts its thread (i.e. this thread).
        e.execute(
            new Runnable() {
              @Override
              public void run() {
                Thread.currentThread().interrupt();
              }
            });
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

      class Interruptenator extends Thread {
        final AtomicBoolean shutdown;
    
        Interruptenator(Thread interruptee) {
          this(interruptee, new AtomicBoolean(false));
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        Interruptenator(Thread interruptee, AtomicBoolean shutdown) {
          super(
              new Runnable() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. 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)
  4. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        }
      }
    
      /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
              Thread.yield();
              break;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
      }
    
      /** Invokes {@code toJoin.}{@link Thread#join() join()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static void joinUninterruptibly(Thread toJoin) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/eventbus/Dispatcher.java

     * thread) the subscriber is actually called when an event is dispatched to it.
     *
     * @author Colin Decker
     */
    abstract class Dispatcher {
    
      /**
       * Returns a dispatcher that queues events that are posted reentrantly on a thread that is already
       * dispatching an event, guaranteeing that all events posted on a single thread are dispatched to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.21.md

      - [Urgent Upgrade Notes](#urgent-upgrade-notes)
        - [(No, really, you MUST read this before you upgrade)](#no-really-you-must-read-this-before-you-upgrade)
      - [Changes by Kind](#changes-by-kind-13)
        - [Deprecation](#deprecation)
        - [API Change](#api-change-3)
        - [Feature](#feature-11)
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Fri Oct 14 07:03:14 UTC 2022
    - 367.3K bytes
    - Viewed (0)
  8. guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/TestPlatform.java

          assertThat(e).hasMessageThat().isEqualTo("Cannot get() on a pending future.");
        }
      }
    
      static void verifyThreadWasNotInterrupted() {
        // There is no thread interruption in GWT, so there's nothing to do.
      }
    
      static void clearInterrupt() {
        // There is no thread interruption in GWT, so there's nothing to do.
      }
    
      static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. docs/contribute/concurrency.md

    So we have a dedicated thread for every socket that just reads frames and dispatches them.
    
    The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    
        @Override
        public @Nullable E poll() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.poll();
        }
    
        @Override
        public E remove() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove();
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
Back to top