Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 481 - 490 of 805 for threadId (0.13 seconds)

  1. docs/en/docs/async.md

    But before that, handling asynchronous code was quite more complex and difficult.
    
    In previous versions of Python, you could have used threads or [Gevent](https://www.gevent.org/). But the code is way more complex to understand, debug, and think about.
    
    In previous versions of NodeJS / Browser JavaScript, you would have used "callbacks". Which leads to "callback hell".
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 23.4K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/ingest/IngestFactory.java

            // Default constructor
        }
    
        /**
         * Adds an ingester to the factory.
         * The ingester is inserted into the collection and the array is re-sorted by priority.
         * This method is thread-safe.
         *
         * @param ingester the ingester to add
         */
        public synchronized void add(final Ingester ingester) {
            if (logger.isDebugEnabled()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/persistent/HandleReconnector.java

                try {
                    // Wait before retry (except first attempt)
                    if (attempt > 0) {
                        long delay = retryDelay * (1L << attempt); // Exponential backoff
                        Thread.sleep(delay);
                        log.debug("Reconnection attempt {} for {}", attempt + 1, info.getPath());
                    }
    
                    // Perform the actual reconnection
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 8.5K bytes
    - Click Count (1)
  4. android/guava/src/com/google/common/hash/BloomFilter.java

     *
     * <p>As of Guava 23.0, this class is thread-safe and lock-free. It internally uses atomics and
     * compare-and-swap to ensure correctness when multiple threads are used to access it.
     *
     * @param <T> the type of instances that the {@code BloomFilter} accepts
     * @author Dimitris Andreou
     * @author Kevin Bourrillion
     * @since 11.0 (thread-safe since 23.0)
     */
    @Beta
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 10 22:28:12 GMT 2026
    - 27.6K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/helper/AbstractConfigHelper.java

    /**
     * The abstract helper for configuration.
     *
     * This class provides a basic framework for managing configurations that can be reloaded.
     * It includes functionality for updating configurations in a separate thread and controlling the reloading interval.
     */
    public abstract class AbstractConfigHelper {
    
        /**
         * Default constructor.
         */
        public AbstractConfigHelper() {
            // Default constructor
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/crawlinginfo/AdminCrawlinginfoAction.java

                        throwValidationError(messages -> messages.addErrorsCrudCouldNotFindCrudTable(GLOBAL, id), this::asListHtml);
                        return null;
                    });
        }
    
        /**
         * Print a thread dump.
         * @param form The edit form.
         * @return The HTML response.
         */
        @Execute
        @Secured({ ROLE })
        public HtmlResponse threaddump(final EditForm form) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 13:56:35 GMT 2025
    - 11K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

        public void finalizeReferent() {
          finalizeReferentCalled = true;
        }
      }
    
      /**
       * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
       * know that the background thread has stopped and released its strong reference.
       */
      private WeakReference<ReferenceQueue<Object>> queueReference;
    
      @Test
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Feb 27 21:20:19 GMT 2026
    - 8.6K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        CountDownLatch doneSignal = new CountDownLatch(1);
        Thread thread =
            new Thread(
                () -> {
                  try {
                    cache.get(key, loader);
                  } catch (UncheckedExecutionException | ExecutionException e) {
                    doneSignal.countDown();
                  }
                });
        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 114.9K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        CountDownLatch doneSignal = new CountDownLatch(1);
        Thread thread =
            new Thread(
                () -> {
                  try {
                    cache.get(key, loader);
                  } catch (UncheckedExecutionException | ExecutionException e) {
                    doneSignal.countDown();
                  }
                });
        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 116.4K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/curl/CurlRequest.java

            } catch (final UnsupportedEncodingException e) {
                throw new CurlException("Invalid encoding: " + encoding, e);
            }
        }
    
        /**
         * Sets the thread pool for executing the request.
         *
         * @param threadPool the thread pool
         * @return this CurlRequest instance
         */
        public CurlRequest threadPool(final ForkJoinPool threadPool) {
            this.threadPool = threadPool;
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 19.7K bytes
    - Click Count (0)
Back to Top