- Sort Score
- Result 10 results
- Languages All
Results 661 - 670 of 796 for Threads (0.04 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/gcs/Handler.java
/** * Establishes a connection to the GCS service. * This method creates a GCS Storage client using environment variables for configuration. * This method is synchronized to ensure thread-safe connection initialization. * * @throws IOException If the connection cannot be established */ @Override public synchronized void connect() throws IOException {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 9.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java
} /** * Establishes a connection to the S3 service. * This method creates an AWS S3 client using environment variables for configuration. * This method is synchronized to ensure thread-safe connection initialization. * * @throws IOException If the connection cannot be established */ @Override public synchronized void connect() throws IOException {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 07:57:44 UTC 2025 - 9.5K bytes - Viewed (0) -
internal/event/target/nsq.go
if err != nil { return err } return target.producer.Publish(target.args.Topic, data) } // SendFromStore - reads an event from store and sends it to NSQ. func (target *NSQTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } _, err := target.isActive() if err != nil {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 7.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java
assertEquals(TransPeekNamedPipeResponse.STATUS_LISTENING, response.getStatus()); // Middle bytes were read but not used } @Test @DisplayName("Test consecutive reads update state correctly") void testConsecutiveReads() { // First read byte[] buffer1 = new byte[10]; SMBUtil.writeInt2(100, buffer1, 0); SMBUtil.writeInt2(0, buffer1, 2);
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
} /** * Creates a thread-safe set backed by a hash map. The set is backed by a {@link * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees. * * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The * set is serializable. * * @return a new, empty thread-safe {@code Set} * @since 15.0 */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 18:35:44 UTC 2025 - 81.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java
SmbClient client = new SmbClient() { @Override protected ResponseData getResponseData(final String uri, final boolean includeContent) { try { Thread.sleep(2000); } catch (InterruptedException e) { throw new CrawlingAccessException(e); } return null; } };
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Tue Sep 23 06:42:59 UTC 2025 - 31.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbOperationException.java
} return String.format("[%s] %s: %s", errorCode.name(), errorCode.getDescription(), message); } private String extractOperationName() { StackTraceElement[] stack = Thread.currentThread().getStackTrace(); for (StackTraceElement element : stack) { String className = element.getClassName(); if (className.startsWith("jcifs.smb") && !className.contains("Exception")) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 16.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* @param executor the executor in which the listeners callback methods will be run. For fast, * lightweight listeners that would be safe to execute in any thread, consider {@link * MoreExecutors#directExecutor}. * @since 13.0 */ void addListener(Listener listener, Executor executor); /** * The lifecycle states of a service. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java
/** * Establishes a connection to the storage service. * This method creates a MinIO client using environment variables for configuration. * This method is synchronized to ensure thread-safe connection initialization. * * @throws IOException If the connection cannot be established */ @Override public synchronized void connect() throws IOException {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:52:56 UTC 2025 - 11.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkArgument; import static java.lang.Thread.currentThread; import static java.util.Arrays.asList; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.annotations.VisibleForTesting;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 11.8K bytes - Viewed (0)