Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 638 for threadId (0.11 sec)

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

          return;
        }
        TimedWaiterThread thread = new TimedWaiterThread(new AbstractFuture<Object>() {}, 2, SECONDS);
        thread.start();
        thread.awaitWaiting();
        Thread.class.getMethod("suspend").invoke(thread);
        // Sleep for enough time to add 1500 milliseconds of overwait to the get() call.
        long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime);
        Thread.sleep(toWaitMillis);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/hash/BloomFilterTest.java

        List<Thread> threads = new ArrayList<>(numThreads);
        List<Throwable> exceptions = new ArrayList<>(numThreads);
        for (int i = 0; i < numThreads; i++) {
          Thread thread = new Thread(task);
          thread.setUncaughtExceptionHandler(
              new UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread t, Throwable e) {
                  exceptions.add(e);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 22K bytes
    - Viewed (0)
  3. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Feb 10 21:03:40 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                });
        assertFalse(task.isDone());
        Thread thread =
            new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      task.run();
                    } finally {
                      exitLatch.countDown();
                    }
                  }
                });
        thread.start();
        enterLatch.await();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                  @Override
                  public Integer call() {
                    return Thread.currentThread().getStackTrace().length;
                  }
                },
                directExecutor());
        settableFuture.set(null);
        assertThat(getDone(stackDepthCheck))
            .isLessThan(Thread.currentThread().getStackTrace().length + 100);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 20:58:01 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  6. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java

        @Nonnull
        Optional<Boolean> alsoMakeDependents();
    
        /**
         * Returns the number of threads used for parallel builds.
         *
         * @return an {@link Optional} containing the number of threads (or "1C" for one thread per CPU core), or empty if not specified
         */
        @Nonnull
        Optional<String> threads();
    
        /**
         * Returns the id of the build strategy to use.
         *
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jun 11 13:14:09 UTC 2025
    - 8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

                    }
                  });
          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 85.7K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
        new Thread(
                () -> {
                  assertThrows(CancellationException.class, future::get);
                  successLatch.countDown();
                })
            .start();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/internal/Finalizer.java

            logger.log(
                Level.INFO, "Failed to create a thread without inherited thread-local values", t);
          }
        }
        if (thread == null) {
          thread = new Thread((ThreadGroup) null, finalizer, threadName);
        }
        thread.setDaemon(true);
    
        try {
          if (inheritableThreadLocals != null) {
            inheritableThreadLocals.set(thread, null);
          }
        } catch (Throwable t) {
          logger.log(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

                return jvmGcObj;
            }).toArray(n -> new JvmGcObj[n]);
            final Threads threads = jvmStats.getThreads();
            final JvmThreadsObj jvmThreadsObj = new JvmThreadsObj();
            jvmObj.threads = jvmThreadsObj;
            jvmThreadsObj.count = threads.getCount();
            jvmThreadsObj.peak = threads.getPeakCount();
            final Classes classes = jvmStats.getClasses();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.7K bytes
    - Viewed (0)
Back to top