- Sort Score
- Num 10 results
- Language All
Results 801 - 810 of 1,394 for each (0.12 seconds)
-
src/test/java/org/codelibs/fess/rank/fusion/RankFusionProcessorConcurrencyTest.java
} } } /** * Test multiple concurrent search operations. * Verifies that parallel searches don't interfere with each other. */ @Test public void test_multipleConcurrentSearches() throws Exception { final int numSearchThreads = 5; final CountDownLatch startLatch = new CountDownLatch(1);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 13.5K bytes - Click Count (0) -
android/guava/src/com/google/common/graph/ArchetypeGraph.java
* Returns true if the edges in this graph are directed. Directed edges connect a {@link * EndpointPair#source() source node} to a {@link EndpointPair#target() target node}, while * undirected edges connect a pair of nodes to each other. */ boolean isDirected(); /** * Returns true if this graph allows self-loops (edges that connect a node to itself). AttemptingCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Nov 11 17:11:16 GMT 2025 - 7.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
import java.util.concurrent.RejectedExecutionException; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
/** * Creates a new {@link ThreadFactory} builder. * * <p><b>Java 21+ users:</b> use {@link Thread#ofPlatform()} instead, translating other calls on * the builder as documented on each method (except for the rarely used {@link #setThreadFactory}, * which does not have an equivalent). */ public ThreadFactoryBuilder() {} /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Dec 29 17:36:00 GMT 2025 - 9.2K bytes - Click Count (0) -
guava/src/com/google/common/cache/Cache.java
*/ void put(K key, V value); /** * Copies all of the mappings from the specified map to the cache. The effect of this call is * equivalent to that of calling {@code put(k, v)} on this map once for each mapping from key * {@code k} to value {@code v} in the specified map. The behavior of this operation is undefined * if the specified map is modified while the operation is in progress. * * @since 12.0 */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8K bytes - Click Count (0) -
cmd/batch-job-common-types.go
type BatchJobRetry struct { line, col int Attempts int `yaml:"attempts" json:"attempts"` // number of retry attempts Delay time.Duration `yaml:"delay" json:"delay"` // delay between each retries } var _ yaml.Unmarshaler = &BatchJobRetry{} // UnmarshalYAML - BatchJobRetry extends unmarshal to extract line, column information func (r *BatchJobRetry) UnmarshalYAML(val *yaml.Node) error {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.9K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/MapTestSuiteBuilder.java
FeatureSpecificTestSuiteBuilder< ?, ? extends OneSizeTestContainerGenerator<Map<K, V>, Entry<K, V>>> parentBuilder) { // TODO: Once invariant support is added, supply invariants to each of the // derived suites, to check that mutations to the derived collections are // reflected in the underlying map. List<TestSuite> derivedSuites = super.createDerivedSuites(parentBuilder);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 20:54:16 GMT 2025 - 11K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbTreeConnectionTraceTest.java
} @ParameterizedTest(name = "Invalid usage causes NPE: {0}") @MethodSource("npePublicGetters") void getters_withoutTree_throwNPE(String name, org.junit.jupiter.api.function.Executable call) { // Each call is invalid without a held tree and should throw NPE assertThrows(NullPointerException.class, call); } static java.util.stream.Stream<Arguments> wrapExceptions() {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 8.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
* * If it is a control frame this will result in a single call to [FrameCallback]. * * If it is a message frame this will result in a single call to [FrameCallback.onReadMessage]. * If the message spans multiple frames, each interleaved control frame will result in a * corresponding call to [FrameCallback]. */ @Throws(IOException::class) fun processNextFrame() { check(!closed) { "closed" } readHeader()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10K bytes - Click Count (0) -
impl/maven-core/lifecycle-executor.txt
We have a lifecycle mapping for the packaging of *jar* below. You see that for this packaging we have a *default* lifecycle and a list of phases where each phase is a comma separated list of goals to run and they are in the form groupId:artifactId:version. <configuration> <lifecycles> <lifecycle> <id>default</id> <phases> <process-resources>org.apache.maven.plugins:maven-resources-plugin:resources</process-resources>
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 9.7K bytes - Click Count (0)