- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 365 for atomic (0.71 sec)
-
api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java
import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.LongAdder; import java.util.function.Predicate; import java.util.stream.Stream; import org.apache.maven.api.Constants; import org.apache.maven.api.ProtoSession;
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jul 18 17:30:19 UTC 2025 - 11.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java
*/ package okhttp3.recipes; import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Proxy; import java.util.List; import java.util.concurrent.atomic.AtomicLong; import okhttp3.Call; import okhttp3.Callback; import okhttp3.Connection; import okhttp3.EventListener; import okhttp3.Handshake; import okhttp3.HttpUrl; import okhttp3.OkHttpClient;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 6.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.ds.callback; import java.util.HashSet; import java.util.Map; import java.util.Set; import java.util.concurrent.atomic.AtomicLong; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.stream.StreamUtil; import org.codelibs.fess.entity.DataStoreParams;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 10.3K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
package mockwebserver3 import assertk.assertThat import assertk.assertions.isEqualTo import java.io.IOException import java.net.HttpURLConnection import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicInteger import mockwebserver3.junit5.StartStop import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout @Timeout(30) class CustomDispatcherTest {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Tests {@link SequentialExecutor}. * * @author JJ Furman */ @NullUnmarked
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 11.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/TestingRemovalListeners.java
package com.google.common.cache; import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.atomic.AtomicInteger; import org.jspecify.annotations.NullUnmarked; /** * Utility {@link RemovalListener} implementations intended for use in testing. * * @author mike nonemacher */ @GwtCompatible @NullUnmarked
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
import java.util.Collections; import java.util.EnumSet; import java.util.LinkedList; import java.util.List; import java.util.Set; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.CIFSContext; import jcifs.CIFSException; import jcifs.DfsReferralData;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 30K bytes - Viewed (0) -
src/test/java/jcifs/SmbSessionTest.java
when(mockSession.getConfig()).thenReturn(mockConfig); java.util.concurrent.CountDownLatch latch = new java.util.concurrent.CountDownLatch(5); java.util.concurrent.atomic.AtomicInteger successCount = new java.util.concurrent.atomic.AtomicInteger(0); for (int i = 0; i < 5; i++) { new Thread(() -> { try {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt
* limitations under the License. */ package okhttp3.internal.publicsuffix import java.io.IOException import java.io.InterruptedIOException import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicBoolean import okio.ByteString import okio.Source import okio.buffer internal abstract class BasePublicSuffixList : PublicSuffixList { /** True after we've attempted to read the list for the first time. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 07:33:49 UTC 2025 - 3.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/query/QueryProcessorTest.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.query; import java.util.concurrent.atomic.AtomicBoolean; import org.apache.lucene.search.MatchAllDocsQuery; import org.apache.lucene.search.Query; import org.codelibs.fess.entity.QueryContext; import org.codelibs.fess.query.QueryProcessor.FilterChain;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 3.5K bytes - Viewed (0)