- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 345 for synchronize (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
writeUtf8("\r\n") write(source, byteCount) writeUtf8("\r\n") } } @Synchronized override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. socket.sink.flush() } @Synchronized override fun close() { if (closed) return closed = true socket.sink.writeUtf8("0\r\n\r\n")
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 17.5K bytes - Viewed (7) -
src/test/java/jcifs/smb/CriticalPerformanceTest.java
boolean contains = pool.contains(null); // Should handle gracefully successCount.incrementAndGet(); } catch (Exception e) { synchronized (exceptions) { exceptions.add(e); } } } long threadEnd = System.nanoTime();
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java
* 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 { if (connected) { return; }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:52:56 UTC 2025 - 11.1K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java
lastChecked = System.currentTimeMillis(); final long timestamp = reloadableFile.lastModified(); if (timestamp != time) { synchronized (reloadableFile) { if (timestamp != lastModified) { createSynonymMap(true); return true; } } }
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 6.7K bytes - Viewed (1) -
dbflute_fess/dfprop/littleAdjustmentMap.dfprop
# /- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - # o refreshMap: (NotRequired - Default map:{projectName=$$AutoDetect$$ ; requestUrl=http://localhost:8386/}) # If you use synchronizer and specify this property, no need to refresh(F5) your eclipse project. # The projectName can be set plural names by slash '/'. e.g. sea/land # #; refreshMap = map:{ # ; projectName = $$AutoDetect$$Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Jul 25 06:04:16 UTC 2015 - 8.8K bytes - Viewed (0) -
internal/cachevalue/cache.go
// If NoWait is set, Get() will return the last good value, // if TTL has expired but 2x TTL has not yet passed, // but will fetch a new value in the background. NoWait bool } // Cache contains a synchronized value that is considered valid // for a specific amount of time. // An Update function must be set to provide an updated value when needed. type Cache[T any] struct { // updateFn must return an updated value.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt
val totalExceptionBytes = bufferedSource.readInt() publicSuffixExceptionListBytes = bufferedSource.readByteString(totalExceptionBytes.toLong()) } synchronized(this) { this.bytes = publicSuffixListBytes!! this.exceptionBytes = publicSuffixExceptionListBytes!! } } finally { readCompleteLatch.countDown() } }Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jul 28 07:33:49 UTC 2025 - 3.6K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/Graph.java
/** * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead */ @Deprecated(since = "4.0.0") class Graph { final Map<String, Set<String>> graph = new LinkedHashMap<>(); synchronized void addEdge(String from, String to) throws CycleDetectedException { if (graph.computeIfAbsent(from, l -> new HashSet<>()).add(to)) {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Feb 25 08:27:34 UTC 2025 - 3.4K bytes - Viewed (0) -
impl/maven-core/src/test/remote-repo/org/apache/maven/plugins/maven-clean-plugin/0.1/maven-clean-plugin-0.1.jar
nothing. false true false false false true org.apache.maven.plugin.coreit.ItMojo java per-lookup once-per-session org.apache.maven maven-plugin-api jar 2.0 org/apache/maven/plugin/coreit/ItMojo.class package org.apache.maven.plugin.coreit; public synchronized class ItMojo extends org.apache.maven.plugin.AbstractMojo { public void ItMojo(); public void execute(); } pom.xml 4.0.0 org.apache.maven.plugins maven-clean-plugin 0.1 maven-plugin Maven Integration Test Plugin A test plugin to assist testing...Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheReferencesTest.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 5.3K bytes - Viewed (0)