- Sort Score
- Num 10 results
- Language All
Results 701 - 710 of 1,335 for concurrent (0.26 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/ForwardingBlockingQueueTest.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 1.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ForwardingFutureTest.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 1.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ForwardingListenableFutureTest.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 1.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/IteratorsTest.java
assertTrue(cycle.hasNext()); cycle.remove(); assertEquals(emptyList(), iterable); assertFalse(cycle.hasNext()); } /** An Iterable whose Iterator is rigorous in checking for concurrent modification. */ private static final class PickyIterable<E> implements Iterable<E> { final List<E> elements; int modCount = 0; PickyIterable(E... elements) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 57.3K bytes - Click Count (0) -
docs/smb3-features/02-persistent-handles-design.md
} } ``` ### 4.5 Persistent Handle Manager ```java package jcifs.internal.smb2.persistent; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.io.*; import java.nio.file.*; public class PersistentHandleManager {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 31.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
import java.io.IOException import java.net.HttpURLConnection import java.net.ProtocolException import java.util.concurrent.BlockingQueue import java.util.concurrent.CountDownLatch import java.util.concurrent.Executors import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 25.8K bytes - Click Count (0) -
src/main/java/jcifs/util/SecureKeyManager.java
private final java.util.concurrent.ScheduledExecutorService rotationScheduler = java.util.concurrent.Executors.newSingleThreadScheduledExecutor(r -> { Thread t = new Thread(r, "SecureKeyManager-Rotation"); t.setDaemon(true); return t; }); private java.util.concurrent.ScheduledFuture<?> rotationTask; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 21.5K bytes - Click Count (0) -
src/main/java/org/codelibs/core/collection/LruHashMap.java
* Map<K, V> syncMap = Collections.synchronizedMap(new LruHashMap<>(100)); * </pre> * <p> * Alternatively, for high-concurrency scenarios, consider implementing a custom * LRU cache using {@link java.util.concurrent.ConcurrentHashMap} with an eviction strategy. * </p> * * @author koichik * @param <K> the key type * @param <V> the value type */ public class LruHashMap<K, V> extends LinkedHashMap<K, V> {
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat Nov 22 11:21:59 GMT 2025 - 3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/RunnablesTest.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import com.google.common.annotations.GwtCompatible; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 1.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleMonitorTest.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 1.1K bytes - Click Count (0)