- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for AtomicBoolean (0.54 sec)
-
src/test/java/org/codelibs/fess/query/QueryProcessorTest.java
import org.opensearch.index.query.QueryBuilders; public class QueryProcessorTest extends UnitFessTestCase { public void test_executeWithFilter() { final AtomicBoolean called = new AtomicBoolean(false); QueryProcessor queryProcessor = new QueryProcessor() { protected FilterChain createDefaultFilterChain() { return (context, query, boost) -> {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
final Monitor monitor, boolean expectedIsOccupied, boolean expectedIsOccupiedByCurrentThread, int expectedOccupiedDepth) { final AtomicBoolean actualIsOccupied = new AtomicBoolean(); final AtomicBoolean actualIsOccupiedByCurrentThread = new AtomicBoolean(); final AtomicInteger actualOccupiedDepth = new AtomicInteger(); final AtomicReference<Throwable> thrown = new AtomicReference<>(); joinUninterruptibly(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.9K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.cache-miss-monitor.gradle.kts
if ((cacheMissInBuildLogic as AtomicBoolean).get() || (cacheMissInMainBuild as AtomicBoolean).get()) { tag("CACHE_MISS") } } } } fun buildCacheEnabled() = gradle.startParameter.isBuildCacheEnabled abstract class CacheMissMonitorBuildService : AbstractBuildScanInfoCollectingService() { private val cacheMiss: AtomicBoolean = AtomicBoolean(false)
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Mar 07 05:49:29 GMT 2024 - 4.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
public void testRemovalNotification_clear() throws InterruptedException { // If a clear() happens while a computation is pending, we should not get a removal // notification. final AtomicBoolean shouldWait = new AtomicBoolean(false); final CountDownLatch computingLatch = new CountDownLatch(1); CacheLoader<String, String> computingFunction = new CacheLoader<String, String>() { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt
import assertk.assertions.isTrue import java.io.IOException import java.io.InputStreamReader import java.io.Reader import java.nio.charset.StandardCharsets import java.util.concurrent.atomic.AtomicBoolean import kotlin.test.assertFailsWith import okhttp3.MediaType.Companion.toMediaType import okhttp3.ResponseBody.Companion.toResponseBody import okhttp3.internal.and import okio.Buffer import okio.BufferedSource
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
final AtomicReference<AbstractFuture<String>> setFutureFuture = Atomics.newReference(); final AtomicBoolean setFutureSetSuccess = new AtomicBoolean(); final AtomicBoolean setFutureCompletionSuccess = new AtomicBoolean(); final AtomicBoolean cancellationSuccess = new AtomicBoolean(); Runnable cancelRunnable = new Runnable() { @Override public void run() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
// This allows us to only start up a thread waiting on the delegate future when the first // listener is added. private final AtomicBoolean hasListeners = new AtomicBoolean(false); // The delegate future. private final Future<V> delegate; ListenableFutureAdapter(Future<V> delegate) { this(delegate, defaultAdapterExecutor); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 7.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ldap/LdapManagerTest.java
assertEquals("a_a", ldapManager.replaceWithUnderscores("a/a")); } public void test_allowEmptyGroupAndRole() { final AtomicBoolean allowEmptyPermission = new AtomicBoolean(); ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() { public boolean isLdapAllowEmptyPermission() { return allowEmptyPermission.get(); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} } @J2ktIncompatible @GwtIncompatible // blocking wait public void testCancel_interrupted() throws Exception { final AtomicBoolean interruptedExceptionThrown = new AtomicBoolean(); final CountDownLatch enterLatch = new CountDownLatch(1); final CountDownLatch exitLatch = new CountDownLatch(1); final TrustedListenableFutureTask<Integer> task =
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} } @J2ktIncompatible @GwtIncompatible // blocking wait public void testCancel_interrupted() throws Exception { final AtomicBoolean interruptedExceptionThrown = new AtomicBoolean(); final CountDownLatch enterLatch = new CountDownLatch(1); final CountDownLatch exitLatch = new CountDownLatch(1); final TrustedListenableFutureTask<Integer> task =
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0)