Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 608 for Thread (0.18 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java

      }
    
      private void streamPrimesToSinkAsynchronously(final BufferedSink sink) {
        Thread thread = new Thread("writer") {
          @Override public void run() {
            try {
              sink.writeUtf8("Numbers\n");
              sink.writeUtf8("-------\n");
              for (int i = 2; i <= 997; i++) {
                System.out.println(i);
                Thread.sleep(10);
                sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i)));
              }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Jul 06 03:18:15 UTC 2018
    - 3.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(final long time, final TimeUnit unit) {
        checkNotNull(unit);
        final Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(final long time, final TimeUnit unit) {
        checkNotNull(unit);
        final Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/SynchronizedQueueTest.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: Mon Aug 19 20:50:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/netns_linux.go

    			return err
    		}
    		defer func() {
    			err := threadNS.Set() // switch back
    			if err == nil {
    				// Unlock the current thread only when we successfully switched back
    				// to the original namespace; otherwise leave the thread locked which
    				// will force the runtime to scrap the current thread, that is maybe
    				// not as optimal but at least always safe to do.
    				runtime.UnlockOSThread()
    			}
    		}()
    
    		return toRun()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 31 10:05:36 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.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: Mon Aug 19 20:50:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/collect/SynchronizedNavigableMapTest.java

        @Override
        public boolean equals(@Nullable Object object) {
          assertTrue(Thread.holdsLock(mutex));
          return super.equals(object);
        }
    
        @Override
        public K getKey() {
          assertTrue(Thread.holdsLock(mutex));
          return super.getKey();
        }
    
        @Override
        public V getValue() {
          assertTrue(Thread.holdsLock(mutex));
          return super.getValue();
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 22:09:38 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

      if (assertionsEnabled && !this.isHeldByCurrentThread) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    internal inline fun Any.assertThreadHoldsLock() {
      if (assertionsEnabled && !Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/lang/ThreadUtil.java

    import org.codelibs.core.log.Logger;
    
    /**
     * Utility class for Thread class
     *
     * @author shinsuke
     *
     */
    public abstract class ThreadUtil {
    
        private static final Logger logger = Logger.getLogger(ThreadUtil.class);
    
        public static void sleep(final long millis) {
            if (millis < 1L) {
                return;
            }
            try {
                Thread.sleep(millis);
            } catch (final InterruptedException e) {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

         *       observing a null thread does not mean the object is safe to reuse.
         *   <li>If this field's value is some other thread object, we know that it's not our thread.
         *   <li>If this field's value == null because it originally belonged to another thread and that
         *       thread cleared it, we still know that it's not associated with our thread
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
Back to top