Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 558 for unread (0.1 sec)

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

      }
    
      /**
       * Causes this thread to call the named method, and asserts that this thread becomes blocked on
       * the lock-like object. The lock-like object must have a method equivalent to {@link
       * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}.
       */
      public void callAndAssertBlocks(String methodName, Object... arguments) throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/base/SuppliersTest.java

                  if (isWaiting(thread)) {
                    waitingThreads++;
                  }
                }
                return waitingThreads;
              }
    
              @Override
              @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races
              public Boolean get() {
                // Check that this method is called exactly once, by the first
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/base/SuppliersTest.java

                  if (isWaiting(thread)) {
                    waitingThreads++;
                  }
                }
                return waitingThreads;
              }
    
              @Override
              @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races
              public Boolean get() {
                // Check that this method is called exactly once, by the first
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        LockingThread thread = new LockingThread(lockA);
        thread.start();
    
        thread.waitUntilHoldingLock();
        assertFalse(lockA.tryLock());
    
        thread.releaseLockAndFinish();
        assertTrue(lockA.tryLock());
      }
    
      public void testReentrantWriteLock_tryLock() throws Exception {
        LockingThread thread = new LockingThread(writeLockA);
        thread.start();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        LockingThread thread = new LockingThread(lockA);
        thread.start();
    
        thread.waitUntilHoldingLock();
        assertFalse(lockA.tryLock());
    
        thread.releaseLockAndFinish();
        assertTrue(lockA.tryLock());
      }
    
      public void testReentrantWriteLock_tryLock() throws Exception {
        LockingThread thread = new LockingThread(writeLockA);
        thread.start();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/timer/TimeoutManager.java

            return instance;
        }
    
        /**
         * 処理を開始します。
         */
        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 Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java

        private static final int MAX_LOOP_COUNT = 10;
    
        protected Thread runningThread;
    
        protected AtomicBoolean running = new AtomicBoolean();
    
        public AccessTimeoutTarget(final Thread thread) {
            runningThread = thread;
            running.set(true);
        }
    
        /*
         * (non-Javadoc)
         *
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/SynchronizedMapTest.java

        }
    
        @Override
        public int size() {
          assertTrue(Thread.holdsLock(mutex));
          return super.size();
        }
    
        @Override
        public boolean isEmpty() {
          assertTrue(Thread.holdsLock(mutex));
          return super.isEmpty();
        }
    
        @Override
        public @Nullable V remove(Object object) {
          assertTrue(Thread.holdsLock(mutex));
          return super.remove(object);
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

      }
    
      /**
       * Causes this thread to call the named method, and asserts that this thread becomes blocked on
       * the lock-like object. The lock-like object must have a method equivalent to {@link
       * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}.
       */
      public void callAndAssertBlocks(String methodName, Object... arguments) throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top