- Sort Score
- Result 10 results
- Languages All
Results 751 - 760 of 1,022 for concurrency (0.05 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) -
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) -
android/guava/src/com/google/common/collect/AbstractMultimap.java
import static com.google.common.base.Preconditions.checkNotNull; 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.Collection; import java.util.Iterator; import java.util.Map; import java.util.Map.Entry;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 6.4K bytes - Viewed (0) -
README.md
- **SLF4J Logging**: Comprehensive logging throughout the codebase - **Resource Management**: AutoCloseable patterns for file handles and connections - **Thread Safety**: Components support concurrent access - **DFS Support**: Distributed File System resolution - **Streaming Operations**: Efficient directory listings and file operations - **Buffer Caching**: Optimized buffer management
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 09:24:52 UTC 2025 - 6.2K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ProjectManager.java
* * The service maintains the mutable state of projects as they progress through * their build lifecycle, ensuring thread-safety and proper state management. * All implementations must be thread-safe as they may be accessed concurrently * during parallel builds. * * @since 4.0.0 * @see org.apache.maven.api.services.ProjectBuilder * @see Project */ @Experimental public interface ProjectManager extends Service { /**
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Thu Jan 30 23:29:13 UTC 2025 - 12K 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) -
guava/src/com/google/common/escape/Escaper.java
* resulting XML document is parsed, the parser API will return this text as the original literal * string {@code "Foo<Bar>"}. * * <p>An {@code Escaper} instance is required to be stateless, and safe when used concurrently by * multiple threads. * * <p>Because, in general, escaping operates on the code points of a string and not on its * individual {@code char} values, it is not safe to assume that {@code escape(s)} is equivalent to
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 15:45:16 UTC 2025 - 4.7K bytes - Viewed (0)