- Sort Score
- Result 10 results
- Languages All
Results 601 - 610 of 931 for CONCURRENT (0.04 sec)
-
src/main/java/jcifs/util/transport/Transport.java
import java.io.InputStream; import java.net.SocketTimeoutException; import java.util.Iterator; import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicLong; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.RuntimeCIFSException; import jcifs.smb.RequestParam; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 27.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskLoggerTest.kt
* 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 okhttp3.internal.concurrent import assertk.assertThat import assertk.assertions.isEqualTo import org.junit.jupiter.api.Test class TaskLoggerTest { @Suppress("ktlint") @Test fun formatTime() {Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/ForwardingLoadingCache.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ExecutionException; /** * A cache which forwards all its method calls to another cache. Subclasses should override one or * more methods to modify the behavior of the backing cache as desired per the <a
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 2.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SneakyThrows.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.GwtCompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; /** Static utility method for unchecked throwing of any {@link Throwable}. */ @GwtCompatibleRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Dec 30 18:44:22 UTC 2024 - 2.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ldap/LdapManagerTest.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.ldap; import java.util.ArrayList; import java.util.Hashtable; import java.util.List; import java.util.concurrent.atomic.AtomicBoolean; import org.codelibs.fess.helper.SystemHelper; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.unit.UnitFessTestCase; import org.codelibs.fess.util.ComponentUtil;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 5.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.io.IOException import java.util.concurrent.TimeUnit /** * Observes, modifies, and potentially short-circuits requests going out and the corresponding * responses coming back in. Typically interceptors add, remove, or transform headers on the request
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheRefreshTest.java
* the License. */ package com.google.common.cache; import static com.google.common.cache.TestingCacheLoaders.incrementingLoader; import static java.util.concurrent.TimeUnit.MILLISECONDS; import com.google.common.cache.TestingCacheLoaders.IncrementingLoader; import com.google.common.testing.FakeTicker; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
import static org.codelibs.core.stream.StreamUtil.stream; import java.io.File; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.concurrent.atomic.AtomicInteger; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.SystemUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
import java.security.cert.CertificateException import java.security.cert.X509Certificate import java.util.Collections import java.util.Locale import java.util.concurrent.ConcurrentHashMap import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicInteger import java.util.logging.Level import java.util.logging.Logger import javax.net.ServerSocketFactory import javax.net.ssl.SSLContext
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 20:36:00 UTC 2025 - 40.3K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/BloomFilterStrategies.java
import com.google.common.math.LongMath; import com.google.common.primitives.Ints; import com.google.common.primitives.Longs; import java.math.RoundingMode; import java.util.Arrays; import java.util.concurrent.atomic.AtomicLongArray; import org.jspecify.annotations.Nullable; /** * Collections of strategies of generating the k * log(M) bits required for an element to be mapped
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.6K bytes - Viewed (0)