- Sort Score
- Result 10 results
- Languages All
Results 651 - 660 of 898 for Concurrent (2.13 sec)
-
src/main/java/org/codelibs/fess/app/web/admin/badword/AdminBadwordAction.java
import java.nio.file.Files; import java.nio.file.Path; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.beans.util.BeanUtil; import org.codelibs.core.concurrent.CommonPoolUtil; import org.codelibs.fess.Constants; import org.codelibs.fess.annotation.Secured; import org.codelibs.fess.app.pager.BadWordPager; import org.codelibs.fess.app.service.BadWordService;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 18.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/auth/chain/AuthenticationChainTest.java
assertEquals(user2, chain.deleteCalls.get(0)); assertEquals("user3", chain.changePasswordCalls.get(0).getKey()); assertEquals(user1, chain.loadCalls.get(0)); } // Test concurrent operations simulation public void test_implementation_sequentialOperations() { TestAuthenticationChain chain = new TestAuthenticationChain(); List<User> users = new ArrayList<>();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 14.6K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/HeldCertificateTest.kt
import assertk.assertions.matches import java.math.BigInteger import java.security.KeyFactory import java.security.spec.PKCS8EncodedKeySpec import java.security.spec.X509EncodedKeySpec import java.util.concurrent.TimeUnit import okhttp3.testing.PlatformRule import okhttp3.tls.HeldCertificate.Companion.decode import okio.ByteString.Companion.decodeBase64 import org.bouncycastle.asn1.x509.GeneralName
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 22.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImplTest.java
import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import jakarta.annotation.PostConstruct; import org.codelibs.fess.entity.DataStoreParams; import org.codelibs.fess.exception.DataStoreException;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 24.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
* limitations under the License. */ package okhttp3.mockwebserver import java.net.InetAddress import java.net.Proxy import java.net.Socket import java.util.concurrent.TimeUnit import javax.net.ServerSocketFactory import javax.net.ssl.SSLSocketFactory import okhttp3.Handshake import okhttp3.Headers import okhttp3.Headers.Companion.headersOf import okhttp3.HttpUrl
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.3K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
import java.util.logging.Logger import javax.net.ssl.SSLSocket import javax.net.ssl.SSLSocketFactory import okhttp3.Protocol import okhttp3.Protocol.Companion.get import okhttp3.internal.closeQuietly import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.connection.asBufferedSocket import okhttp3.internal.http2.Header import okhttp3.internal.http2.Http2Connection import okhttp3.internal.http2.Http2Stream
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 6.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractTable.java
import static com.google.common.collect.Maps.safeGet; import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.concurrent.LazyInit; import com.google.j2objc.annotations.WeakOuter; import java.util.AbstractCollection; import java.util.AbstractSet; import java.util.Collection; import java.util.Iterator; import java.util.Map;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 6.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
import java.io.InterruptedIOException import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicInteger import kotlin.test.assertFailsWith import okhttp3.Headers import okhttp3.Headers.Companion.headersOf import okhttp3.TestUtil.headerEntries import okhttp3.TestUtil.repeat import okhttp3.internal.EMPTY_BYTE_ARRAY import okhttp3.internal.concurrent.Lockable
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/AbstractCacheTest.java
import com.google.common.cache.AbstractCache.StatsCounter; import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import java.util.ArrayList; import java.util.List; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Unit test for {@link AbstractCache}. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessRegistration.java
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.witness; import java.net.InetAddress; import java.util.concurrent.atomic.AtomicLong; /** * Represents a witness service registration for SMB resource monitoring. * This class maintains registration state, heartbeat information, and
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Mon Aug 25 14:34:10 UTC 2025 - 6.7K bytes - Viewed (0)