Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,054 for Spread (0.09 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

        protected CrawlerContext crawlerContext;
    
        protected boolean background = false;
    
        protected boolean daemon = false;
    
        protected int threadPriority = Thread.NORM_PRIORITY;
    
        protected Thread parentThread;
    
        protected ThreadGroup crawlerThreadGroup;
    
        public Crawler() {
            crawlerContext = new CrawlerContext();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * The particular nature and strength of the guarantees made by the proxy is
       * implementation-dependent. However, it is important that each of the methods on the target
       * object behaves appropriately when its thread is interrupted.
       *
       * <p>For example, to return the value of {@code target.someMethod()}, but substitute {@code
       * DEFAULT_VALUE} if this method call takes over 50 ms, you can use this code:
       *
       * <pre>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Interners.java

              /* Someone beat us to it! Trying again...
               *
               * Technically this loop not guaranteed to terminate, so theoretically (extremely
               * unlikely) this thread might starve, but even then, there is always going to be another
               * thread doing progress here.
               */
            }
          }
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 13 14:30:51 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        final CountDownLatch doneSignal = new CountDownLatch(1);
    
        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler(
            new UncaughtExceptionHandler() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        final CountDownLatch doneSignal = new CountDownLatch(1);
    
        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler(
            new UncaughtExceptionHandler() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

      /**
       * Returns an exception handler that exits the system. This is particularly useful for the main
       * thread, which may start up other, non-daemon threads, but fail to fully initialize the
       * application successfully.
       *
       * <p>Example usage:
       *
       * <pre>
       * public static void main(String[] args) {
       *   Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());
       *   ...
       * </pre>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/EventListener.kt

      /**
       * Invoked when a call is canceled.
       *
       * Like all methods in this interface, this is invoked on the thread that triggered the event. But
       * while other events occur sequentially; cancels may occur concurrently with other events. For
       * example, thread A may be executing [responseBodyStart] while thread B executes [canceled].
       * Implementations must support such concurrent calls.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/netbios/NameServiceClientImpl.java

        }
    
    
        private static void interruptThreadSafely ( QueryThread thread ) {
            try {
                thread.interrupt();
            }
            catch ( SecurityException e ) {
                e.printStackTrace();
            }
        }
    
    
        private static void joinThread ( Thread thread ) {
            try {
                thread.join();
            }
            catch ( InterruptedException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 14 14:26:22 UTC 2022
    - 38.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // Thread.interrupt
      public void testGetUnchecked_interrupted() {
        Thread.currentThread().interrupt();
        try {
          assertEquals("foo", getUnchecked(immediateFuture("foo")));
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // Thread.interrupt
      public void testGetUnchecked_interrupted() {
        Thread.currentThread().interrupt();
        try {
          assertEquals("foo", getUnchecked(immediateFuture("foo")));
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top