Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 740 for Thread (0.72 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultClasspathTransformation.java

            }
        }
    
        // ===================================================================================================
        /**
         * Helper class to traverse graph. Required to make the containing method thread-safe
         * and yet use class level data to lessen stack usage in recursion
         */
        private class ClasspathGraphVisitor {
            MetadataGraph graph;
    
            ClasspathContainer cpc;
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jul 23 17:27:08 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

            final long elapsed2 = (System.nanoTime() - start2) / 1000000;
            assertTrue("Second access should delay at least 100ms", elapsed2 >= 90);
        }
    
        /**
         * Test that cache is thread-safe with concurrent access
         */
        public void test_cacheThreadSafety() {
            final int numTasks = 50;
            final Long waittime = 50L;
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt

            .build()
        val request = Request(server.url("/"))
        val response1 = client.newCall(request).execute()
        assertThat(response1.body.string()).isEqualTo("a")
    
        // Give the thread pool a chance to evict.
        Thread.sleep(500)
        val response2 = client.newCall(request).execute()
        assertThat(response2.body.string()).isEqualTo("b")
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 12.2K bytes
    - Viewed (1)
  4. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

       * Futures#addCallback addCallback()}.
       *
       * <p>Memory consistency effects: Actions in a thread prior to adding a listener <a
       * href="https://docs.oracle.com/javase/specs/jls/se7/html/jls-17.html#jls-17.4.5">
       * <i>happen-before</i></a> its execution begins, perhaps in another thread.
       *
       * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/ForwardingNavigableSet.java

     * contract.
     *
     * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Louis Wasserman
     * @since 12.0
     */
    @GwtIncompatible
    public abstract class ForwardingNavigableSet<E extends @Nullable Object>
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * Futures#addCallback addCallback()}.
       *
       * <p>Memory consistency effects: Actions in a thread prior to adding a listener <a
       * href="https://docs.oracle.com/javase/specs/jls/se7/html/jls-17.html#jls-17.4.5">
       * <i>happen-before</i></a> its execution begins, perhaps in another thread.
       *
       * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  7. 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 Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jun 11 13:14:09 UTC 2025
    - 8K bytes
    - Viewed (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/ConsoleMavenTransferListener.java

    import org.eclipse.aether.transfer.TransferEvent;
    import org.eclipse.aether.transfer.TransferResource;
    
    /**
     * Console download progress meter.
     * <p>
     * This listener is not thread-safe and should be wrapped in the {@link SimplexTransferListener} in a multi-threaded scenario.
     */
    public class ConsoleMavenTransferListener extends AbstractMavenTransferListener {
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Nov 22 14:09:32 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. docs/changelogs/changelog_1x.md

     * Support asynchronous disconnects by breaking the socket only. This should
       prevent flakiness from multiple threads concurrently accessing a stream.
    
    ## Version 1.5.3
    
    _2014-03-29_
    
     * Fix bug where the Content-Length header was not always dropped when
       following a redirect from a POST to a GET.
     * Implement basic support for `Thread.interrupt()`. OkHttp now checks
       for an interruption before doing a blocking call. If it is interrupted,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/Queues.java

              }
              buffer.add(e);
              added++;
            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
        return added;
      }
    
      /**
       * Returns a synchronized (thread-safe) queue backed by the specified queue. In order to guarantee
       * serial access, it is critical that <b>all</b> access to the backing queue is accomplished
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 18K bytes
    - Viewed (0)
Back to top