- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 154 for Synchronized (0.48 sec)
-
src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java
} /** * Adds a key-value pair to the information map. * Initializes the info map as a synchronized LinkedHashMap if it doesn't exist. * * @param key the parameter key to store * @param value the parameter value to store */ public synchronized void putToInfoMap(final String key, final String value) { if (infoMap == null) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 15.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt
hitCount++ } } @Synchronized internal fun trackConditionalCacheHit() { hitCount++ } @Synchronized fun networkCount(): Int = networkCount @Synchronized fun hitCount(): Int = hitCount @Synchronized fun requestCount(): Int = requestCount private inner class RealCacheRequest(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 26.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// Lock while we check state. We must maintain the lock while adding the new pair so that // another thread can't run the list out from under us. We only add to the list if we have not // yet started execution. synchronized (this) { if (!executed) { runnables = new RunnableExecutorPair(runnable, executor, runnables); return; } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/PathMappingHelper.java
* * @param text the text containing URLs * @return the text with replaced URLs */ public String replaceUrls(final String text) { if (cachedPathMappingList == null) { synchronized (this) { if (cachedPathMappingList == null) { init(); } } } String result = text;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 9.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Lockable.kt
import kotlin.contracts.ExperimentalContracts import kotlin.contracts.InvocationKind import kotlin.contracts.contract import okhttp3.internal.assertionsEnabled /** * Marker interface for objects that use the JVM's `synchronized` mechanism and the related * `wait()` and `notify()` functions. * * The Lockable interface is particularly handy because it ensures we lock the right `this` when * there are multiple `this` objects in scope. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 2.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/TearDownStack.java
} @Override public final void addTearDown(TearDown tearDown) { synchronized (lock) { stack.addFirst(checkNotNull(tearDown)); } } /** Causes teardown to execute. */ public final void runTearDown() { List<Throwable> exceptions = new ArrayList<>(); List<TearDown> stackCopy; synchronized (lock) { stackCopy = new ArrayList<>(stack); stack.clear(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 2.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/TearDownStack.java
} @Override public final void addTearDown(TearDown tearDown) { synchronized (lock) { stack.addFirst(checkNotNull(tearDown)); } } /** Causes teardown to execute. */ public final void runTearDown() { List<Throwable> exceptions = new ArrayList<>(); List<TearDown> stackCopy; synchronized (lock) { stackCopy = new ArrayList<>(stack); stack.clear(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Suppliers.java
@SuppressWarnings("SynchronizeOnNonFinalField") public T get() { // A 2-field variant of Double Checked Locking. if (!initialized) { synchronized (lock) { if (!initialized) { T t = delegate.get(); value = t; initialized = true; return t; } } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 16.5K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
results: MutableList<InetAddress>, failures: MutableList<Exception>, ) { try { val addresses = readResponse(hostname, response) synchronized(results) { results.addAll(addresses) } } catch (e: Exception) { synchronized(failures) { failures.add(e) } } } @Throws(UnknownHostException::class) private fun throwBestFailure(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 8.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionList.java
// Lock while we check state. We must maintain the lock while adding the new pair so that // another thread can't run the list out from under us. We only add to the list if we have not // yet started execution. synchronized (this) { if (!executed) { runnables = new RunnableExecutorPair(runnable, executor, runnables); return; } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0)