Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 688 for Thread (0.05 sec)

  1. src/main/java/org/codelibs/core/timer/TimeoutManager.java

            return instance;
        }
    
        /**
         * Starts the process.
         */
        public synchronized void start() {
            if (thread == null) {
                thread = new Thread(this, "CoreLib-TimeoutManager");
                thread.setDaemon(true);
                thread.start();
                if (logger.isDebugEnabled()) {
                    logger.debug("TimeoutManager started.");
                }
            }
        }
    
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        Stopwatch stopwatch = Stopwatch.createStarted();
        Thread thread = new Thread(new JoinTarget(15));
        thread.start();
        thread.join();
        assertFalse(thread.isAlive());
    
        joinUninterruptibly(thread);
        joinUninterruptibly(thread, 0, MILLISECONDS);
        joinUninterruptibly(thread, -42, MILLISECONDS);
        joinUninterruptibly(thread, LONG_DELAY_MS, MILLISECONDS);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  3. 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)
  4. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  5. 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)
  6. guava/src/com/google/common/util/concurrent/Monitor.java

       * <p>On the other hand, if a signalled thread wakes up to discover that its guard is still not
       * satisfied, it does *not* need to call this method before returning to wait. This can only
       * happen due to spurious wakeup (ignorable) or another thread acquiring the lock before the
       * current thread can and returning the guard to the unsatisfied state. In the latter case the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

         * exception. But there's another race: If the first thread fails with an exception and a second
         * thread immediately fails with the same exception:
         *
         * Thread1: calls setException(), which returns true, context switch before it can CAS
         * seenExceptionsField to its exception
         *
         * Thread2: calls setException(), which returns false, CASes seenExceptionsField to its
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

              public @Nullable Void call() throws Exception {
                assertEquals(Thread.currentThread().getName(), newName.get());
                return null;
              }
            };
        Callables.threadRenaming(callable, newName).call();
        assertEquals(oldName, Thread.currentThread().getName());
      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testRenaming_exceptionalReturn() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          // unpark even though the thread has already removed itself from the list. But even if we did
          // use a CAS, that race would still exist (it would just be ever so slightly smaller).
          Thread w = thread;
          if (w != null) {
            thread = null;
            LockSupport.unpark(w);
          }
        }
      }
    
      /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          // unpark even though the thread has already removed itself from the list. But even if we did
          // use a CAS, that race would still exist (it would just be ever so slightly smaller).
          Thread w = thread;
          if (w != null) {
            thread = null;
            LockSupport.unpark(w);
          }
        }
      }
    
      /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
Back to top