- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for AtomicReference (0.79 sec)
-
src/test/java/org/codelibs/fess/ds/DataStoreTest.java
final AtomicBoolean storeCalled = new AtomicBoolean(false); final AtomicReference<DataConfig> capturedConfig = new AtomicReference<>(); final AtomicReference<IndexUpdateCallback> capturedCallback = new AtomicReference<>(); final AtomicReference<DataStoreParams> capturedParams = new AtomicReference<>(); dataStore = new DataStore() { @Override
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 13K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ldap/LdapUserTest.java
public void test_getPermissions_withLdapConfig() { // Test with LDAP configuration final AtomicBoolean activityHelperCalled = new AtomicBoolean(false); final AtomicReference<String[]> rolesFromCallback = new AtomicReference<>(); ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() { @Override public String getLdapBaseDn() { return "dc=example,dc=com";Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 16.6K bytes - Viewed (0) -
src/main/java/jcifs/util/SimpleCircuitBreaker.java
public enum State { CLOSED, // Normal operation OPEN, // Failing, requests blocked HALF_OPEN // Testing recovery } private final String name; private final AtomicReference<State> state = new AtomicReference<>(State.CLOSED); private final AtomicInteger consecutiveFailures = new AtomicInteger(0); private final AtomicInteger halfOpenSuccesses = new AtomicInteger(0);Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 11.3K bytes - Viewed (0) -
guava/src/com/google/common/reflect/Types.java
return (type instanceof Class) ? ((Class<?>) type).getName() : type.toString(); } static @Nullable Type getComponentType(Type type) { checkNotNull(type); AtomicReference<@Nullable Type> result = new AtomicReference<>(); new TypeVisitor() { @Override void visitTypeVariable(TypeVariable<?> t) { result.set(subtypeOfComponentType(t.getBounds())); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Sep 03 14:03:14 UTC 2025 - 23.5K bytes - Viewed (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
*/ OPEN, /** * Testing if service has recovered */ HALF_OPEN } private final String name; private final AtomicReference<State> state = new AtomicReference<>(State.CLOSED); private final AtomicInteger failureCount = new AtomicInteger(0); private final AtomicInteger successCount = new AtomicInteger(0);Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0) -
android/guava/src/com/google/common/reflect/Types.java
return (type instanceof Class) ? ((Class<?>) type).getName() : type.toString(); } static @Nullable Type getComponentType(Type type) { checkNotNull(type); AtomicReference<@Nullable Type> result = new AtomicReference<>(); new TypeVisitor() { @Override void visitTypeVariable(TypeVariable<?> t) { result.set(subtypeOfComponentType(t.getBounds())); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Sep 03 14:03:14 UTC 2025 - 23.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java
final List<String> sessionIdList = Arrays.asList("session1"); indexUpdater.setSessionIdList(sessionIdList); final AtomicReference<Throwable> caughtException = new AtomicReference<>(); indexUpdater.setUncaughtExceptionHandler((t, e) -> caughtException.set(e)); // Make dataService throw ContainerNotAvailableException
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 33K bytes - Viewed (0)