- Sort Score
- Result 10 results
- Languages All
Results 651 - 660 of 823 for Threads (0.18 sec)
-
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) -
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) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
private fun BufferedSource.skipRestOfLine() { when (val newline = indexOf('\n'.code.toByte())) { -1L -> skip(buffer.size) // Exhaust this source. else -> skip(newline + 1) } } /** * Reads lines from `IdnaMappingTable.txt`. * * Comment lines are either blank or start with a `#` character. Lines may also end with a comment. * All comments are ignored. *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/AbstractTableTest.java
import java.util.Map; import org.jspecify.annotations.NonNull; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Test cases for a {@link Table} implementation supporting reads and writes. * * @author Jared Levy * @author Louis Wasserman */ @GwtCompatible @NullMarked public abstract class AbstractTableTest<C extends @Nullable Character> extends AbstractTableReadTest<C> {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 6K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
metricsLogIf(ctx, err) } else { loadProcFSMetrics(ctx, p, m) } } if globalIsDistErasure && globalLockServer != nil { st := globalLockServer.stats() m.Set(processLocksReadTotal, float64(st.Reads)) m.Set(processLocksWriteTotal, float64(st.Writes)) } return nil
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Jun 20 17:55:03 UTC 2024 - 6.5K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
// err will only be returned after decoded has been closed. err *error readCloser io.ReadCloser onReaderExit func() exitReader chan struct{} readerWg sync.WaitGroup } // Read - reads single record. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { v, ok := <-r.decoded if !ok { if r.err != nil && *r.err != nil { return nil, errJSONParsingError(*r.err) } return nil, io.EOF }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K 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)