- Sort Score
- Result 10 results
- Languages All
Results 691 - 700 of 713 for threads (0.06 sec)
-
guava/src/com/google/common/collect/ImmutableList.java
* element (the given list itself). * * <p>This method is safe to use even when {@code elements} is a synchronized or concurrent * collection that is currently being modified by another thread. * * @throws NullPointerException if {@code elements} contains a null element */ public static <E> ImmutableList<E> copyOf(Collection<? extends E> elements) { if (elements instanceof ImmutableCollection) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Nov 17 22:50:48 UTC 2025 - 30.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java
* undocumented and subject to change. * * <p>This method is safe to use even when {@code sortedMultiset} is a synchronized or concurrent * collection that is currently being modified by another thread. * * @throws NullPointerException if {@code sortedMultiset} or any of its elements is null */ public static <E> ImmutableSortedMultiset<E> copyOfSorted(SortedMultiset<E> sortedMultiset) {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 35.2K bytes - Viewed (0) -
impl/maven-core/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar
org.codehaus.plexus.util.cli; public abstract interface StreamConsumer { public abstract void consumeLine(String); } org/codehaus/plexus/util/cli/StreamFeeder.class package org.codehaus.plexus.util.cli; public synchronized class StreamFeeder extends Thread { private java.io.InputStream input; private java.io.OutputStream output; private boolean done; public void StreamFeeder(java.io.InputStream, java.io.OutputStream); public void run(); public void close(); public boolean isDone(); private void feed()...Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 164.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterables.java
* an item to be immediately dequeued for return on a subsequent call to {@link Iterator#next()}. * * <p>Whether the input {@code iterable} is a {@link Queue} or not, the returned {@code Iterable} * is not thread-safe. * * @param iterable the iterable to wrap * @return a view of the supplied iterable that wraps each generated iterator through {@linkRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 16 18:35:28 UTC 2025 - 43.8K bytes - Viewed (0) -
docs/es/docs/deployment/concepts.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Dec 16 16:33:45 UTC 2025 - 20.1K bytes - Viewed (0) -
src/archive/tar/reader.go
// // Note that the GNU manual says that numeric values should be encoded in octal // format. However, the GNU tar utility itself outputs these values in decimal. // As such, this library treats values as being encoded in decimal. func readGNUSparseMap1x0(r io.Reader) (sparseDatas, error) { var ( cntNewline int64 buf bytes.Buffer blk block totalSize int )
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Oct 07 19:46:36 UTC 2025 - 26.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java
// start AccessTimeoutTarget accessTimeoutTarget = null; TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread()); accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); } try { return processHttpMethod(url, httpRequest);Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 12:19:14 UTC 2025 - 53.7K bytes - Viewed (0) -
okhttp/src/androidMain/baseline-prof.txt
HSPLkotlinx/coroutines/AbstractCoroutine;->resumeWith(Ljava/lang/Object;)V HSPLkotlinx/coroutines/Active;-><clinit>()V HSPLkotlinx/coroutines/Active;-><init>()V HSPLkotlinx/coroutines/BlockingEventLoop;-><init>(Ljava/lang/Thread;)V HSPLkotlinx/coroutines/CancelHandler;-><init>()V HSPLkotlinx/coroutines/CancellableContinuationImpl;-><clinit>()V HSPLkotlinx/coroutines/CancellableContinuationImpl;-><init>(Lkotlin/coroutines/Continuation;I)V
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.9K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
import jakarta.annotation.PostConstruct; /** * Manages LDAP connections and operations. */ public class LdapManager { private static final Logger logger = LogManager.getLogger(LdapManager.class); /** A thread-local variable to hold the directory context. */ protected ThreadLocal<DirContextHolder> contextLocal = new ThreadLocal<>(); /** A flag to indicate if the LDAP connection is bound. */Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 86.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
} throw new SearchEngineClientException("client is not HttpClient."); } // // Fesen Client // /** * Gets the thread pool used by the client. * * @return the thread pool */ @Override public ThreadPool threadPool() { return client.threadPool(); } /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 122.4K bytes - Viewed (1)