Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 558 for unread (0.21 sec)

  1. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

            // be ignored; see tryClose comment.
            if( socket == null ) {
                socket = new DatagramSocket( lport, laddr );
                thread = new Thread( this, "JCIFS-NameServiceClient" );
                thread.setDaemon( true );
                thread.start();
            }
        }
        void tryClose() {
            synchronized( LOCK ) {
    
                /* Yes, there is the potential to drop packets
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 17.4K bytes
    - Viewed (0)
  2. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *   <li>a {@linkplain ThreadFactoryBuilder#setNameFormat naming format}
     *   <li>a {@linkplain Thread#setPriority thread priority}
     *   <li>an {@linkplain Thread#setUncaughtExceptionHandler uncaught exception handler}
     *   <li>a {@linkplain ThreadFactory#newThread backing thread factory}
     * </ul>
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:50:54 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

        @Override
        public String toString() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.toString();
        }
    
        @Override
        public boolean equals(@Nullable Object o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.equals(o);
        }
    
        @Override
        public int hashCode() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.hashCode();
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

    public class DeferredTest {
        @Test
        public void test_doneBeforeResolve() throws Exception {
            final Deferred<SuggestResponse> deferred = new Deferred<>();
    
            Thread th = new Thread(() -> {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException ignore) {}
                deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null));
            });
            th.start();
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

              @Override
              void afterRanInterruptiblyFailure(Throwable error) {}
            };
        Thread runner = new Thread(task, "runner");
        runner.start();
        isInterruptibleRegistered.await();
        // trigger the interrupt on another thread since it will block
        Thread interrupter =
            new Thread("Interrupter") {
              @Override
              public void run() {
                task.interruptTask();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
       * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and
       * fails.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
       * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and
       * fails.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

            // start
            AccessTimeoutTarget accessTimeoutTarget = null;
            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            try {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  10. 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)
Back to top