- Sort Score
- Result 10 results
- Languages All
Results 631 - 640 of 796 for Threads (0.05 sec)
-
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
import org.opensearch.index.query.QueryBuilders; import org.opensearch.search.SearchHit; import org.opensearch.search.sort.SortBuilder; import org.opensearch.transport.client.Client; /** * <p> * {@link ESSourceReader} reads documents from Elasticsearch using the scroll API. * It implements the {@link DocumentReader} interface to provide a way to iterate over documents * in a large index without loading all of them into memory at once. * </p> *Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 11.1K bytes - Viewed (0) -
internal/event/target/redis.go
if err != nil { return err } if _, err := conn.Do("RPUSH", target.args.Key, data); err != nil { return err } } return nil } // SendFromStore - reads an event from store and sends it to redis. func (target *RedisTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } conn := target.pool.Get() defer conn.Close()Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 9.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
@Override public void run() {} } @Keep public static final class DummyThreadFactory implements ThreadFactory, Serializable { @Override public Thread newThread(Runnable r) { return new Thread(r); } } @Keep public static final class DummyExecutor implements Executor, Serializable { @Override public void execute(Runnable command) {} }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 21.4K bytes - Viewed (0) -
README.md
- **Logging Abstraction** (`org.codelibs.core.log`) - Flexible logging system supporting JCL (Jakarta Commons Logging) and JUL (Java Util Logging) - **Concurrent Utilities** (`org.codelibs.core.concurrent`) - Thread-safe collections and concurrency helpers using modern concurrent APIs - **Crypto & Security** (`org.codelibs.core.crypto`, `org.codelibs.core.security`) - Basic cryptographic utilities, message digest operations, and secure random generation
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sun Aug 31 02:56:02 UTC 2025 - 12.7K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb1/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 - 30K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/SuggesterTest.java
suggester.refresh(); // Minimal sleep to ensure timestamp separation (reduced from 2000ms to 100ms total) Thread.sleep(50); ZonedDateTime threshold = ZonedDateTime.now(); Thread.sleep(50); // Index new data after threshold suggester.indexer().indexFromDocument(new Map[] { Collections.singletonMap(field, (Object) "検索エンジン") });
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 37.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} } } /** * Dispatches all events enqueued prior to this call, serially and in order, for every listener. * * <p>Note: this method is idempotent and safe to call from any thread */ public void dispatch() { // iterate by index to avoid concurrent modification exceptions for (int i = 0; i < listeners.size(); i++) { listeners.get(i).dispatch(); } }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0) -
impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/PluginUpgradeCliTest.java
ByteArrayOutputStream err = new ByteArrayOutputStream(); int exit = MavenUpCling.main( new String[] {"--help"}, new ClassWorld("plexus.core", Thread.currentThread().getContextClassLoader()), null, out, err); String help = out.toString(StandardCharsets.UTF_8);
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Mon Sep 29 14:48:39 UTC 2025 - 9.9K bytes - Viewed (0) -
internal/http/listener.go
return } } } // Start separate goroutine for each listener to handle connection. for idx, ln := range listener.listeners { go handleListener(idx, ln) } } // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same. func (listener *httpListener) Accept() (conn net.Conn, err error) { select { case result := <-listener.acceptCh:Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/SMB1SigningDigest.java
update(sequence, 0, sequence.length); index += 8; if (msg.getCommand() == ServerMessageBlock.SMB_COM_READ_ANDX) { /* * SmbComReadAndXResponse reads directly from the stream into separate byte[] b. */ final SmbComReadAndXResponse raxr = (SmbComReadAndXResponse) msg; final int length = msg.getLength() - raxr.getDataLength();
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11.9K bytes - Viewed (0)