- Sort Score
- Result 10 results
- Languages All
Results 551 - 560 of 711 for thread (0.05 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java
// start AccessTimeoutTarget accessTimeoutTarget = null; TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread()); accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); } try {Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 39.5K bytes - Viewed (0) -
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 Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 29.5K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 43.6K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/Longs.java
* in the manner of {@link Number#longValue}. * * <p>Elements are copied from the argument collection as if by {@code collection.toArray()}. * Calling this method is as thread-safe as calling that method. * * @param collection a collection of {@code Number} instances * @return an array containing the same values as {@code collection}, in the same order, converted * to primitivesRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 29.1K bytes - Viewed (0) -
src/main/java/jcifs/SmbResource.java
* exists and is not marked read-only. By default, resources are * considered to be read-only and therefore for <code>smb://</code>, * <code>smb://workgroup/</code>, and <code>smb://server/</code> resources * will be read-only. * * @return <code>true</code> if the resource exists is not marked * read-onlyRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 28K 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: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 82K 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 Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.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: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 52.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
synchronized (this) { // Double-check usage count within synchronized block if (this.usageCount.get() != 0) { return; // Another thread acquired the session } if (this.transportAcquired.compareAndSet(true, false)) { this.transport.release(); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 68.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
* Tests to see if the file this <code>SmbFile</code> represents can be * read. Because any file, directory, or other resource can be read if it * exists, this method simply calls the <code>exists</code> method. * * @return <code>true</code> if the file is read-only * @throws SmbException if an error occurs while checking read permissions */ public boolean canRead() throws SmbException {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 112.2K bytes - Viewed (0)