Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 467 for runnable (0.11 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

       */
      protected ScheduledExecutorService executor() {
        @WeakOuter
        class ThreadFactoryImpl implements ThreadFactory {
          @Override
          public Thread newThread(Runnable runnable) {
            return MoreExecutors.newThread(serviceName(), runnable);
          }
        }
        final ScheduledExecutorService executor =
            Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

    /**
     * Tests for ThreadFactoryBuilder.
     *
     * @author Kurt Alfred Kluever
     * @author Martin Buchholz
     */
    public class ThreadFactoryBuilderTest extends TestCase {
      private final Runnable monitoredRunnable =
          new Runnable() {
            @Override
            public void run() {
              completed = true;
            }
          };
    
      private static final UncaughtExceptionHandler UNCAUGHT_EXCEPTION_HANDLER =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java

            }
          };
      private static final Runnable GOOD_RUNNABLE =
          new Runnable() {
            @Override
            public void run() {
              try {
                MILLISECONDS.sleep(DELAY_MS);
              } catch (InterruptedException e) {
                throw new RuntimeException(e);
              }
            }
          };
      private static final Runnable BAD_RUNNABLE =
          new Runnable() {
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 9.5K bytes
    - Viewed (0)
  4. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

        }
      }
    
      // This exclusion doesn't exclude the TOMBSTONE objects we set. So 'done' NEW futures will look
      // larger than they are.
      @SuppressWarnings("FutureReturnValueIgnored")
      @Footprint(exclude = {Runnable.class, Executor.class, Thread.class, Exception.class})
      public Object measureSize() {
        for (Thread thread : blockedThreads) {
          thread.interrupt();
        }
        blockedThreads.clear();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java

    public class CommonPoolUtil {
        private static final Logger logger = Logger.getLogger(CommonPoolUtil.class);
    
        private CommonPoolUtil() {
            // nothing
        }
    
        public static void execute(final Runnable task) {
            ForkJoinPool.commonPool().execute(() -> {
                final Thread currentThread = Thread.currentThread();
                final ClassLoader orignal = currentThread.getContextClassLoader();
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

              @Override
              public String get(long time, TimeUnit unit) {
                return "foo"; // BAD!!
              }
    
              @Override
              public void addListener(Runnable runnable, Executor executor) {
                executor.execute(runnable);
              }
            };
        Future<?> future = newFutureInstance();
        future
            .getClass()
            .getMethod(
                "setFuture",
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

              @Override
              public String get(long time, TimeUnit unit) {
                return "foo"; // BAD!!
              }
    
              @Override
              public void addListener(Runnable runnable, Executor executor) {
                executor.execute(runnable);
              }
            };
        Future<?> future = newFutureInstance();
        future
            .getClass()
            .getMethod(
                "setFuture",
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

        AtomicLong count = (nameFormat != null) ? new AtomicLong(0) : null;
        return new ThreadFactory() {
          @Override
          public Thread newThread(Runnable runnable) {
            Thread thread = backingThreadFactory.newThread(runnable);
            // TODO(b/139735208): Figure out what to do when the factory returns null.
            requireNonNull(thread);
            if (nameFormat != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:50:54 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/ReflectionFreeAssertThrows.java

      }
    
      @CanIgnoreReturnValue
      static <T extends Throwable> T assertThrows(
          Class<T> expectedThrowable, ThrowingRunnable runnable) {
        return doAssertThrows(
            expectedThrowable,
            () -> {
              runnable.run();
              return null;
            },
            /* userPassedSupplier= */ false);
      }
    
      private static <T extends Throwable> T doAssertThrows(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/esreq/AdminEsreqAction.java

                return curlHelper.delete(path);
            default:
                break;
            }
            return null;
        }
    
        private HtmlResponse asListHtml(final Runnable runnable) {
            if (runnable != null) {
                runnable.run();
            }
            return asHtml(path_AdminEsreq_AdminEsreqJsp).useForm(UploadForm.class);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 6.2K bytes
    - Viewed (0)
Back to top