- Sort Score
- Result 10 results
- Languages All
Results 681 - 690 of 1,022 for concurrency (0.12 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt
import assertk.assertions.isIn import assertk.assertions.isLessThan import assertk.assertions.isNull import assertk.assertions.isTrue import java.lang.Thread.sleep import java.util.concurrent.TimeUnit import kotlin.concurrent.thread import kotlin.test.assertFailsWith import kotlin.time.Duration import kotlin.time.Duration.Companion.milliseconds import kotlin.time.measureTime import mockwebserver3.MockResponse
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 18K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java
import static com.google.common.cache.TestingCacheLoaders.identityLoader; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.TimeUnit.DAYS; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.base.Function; import com.google.common.cache.CacheBuilderFactory.DurationSpec;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 15.1K bytes - Viewed (0) -
okhttp-tls/api/okhttp-tls.api
public final fun certificateAuthority (I)Lokhttp3/tls/HeldCertificate$Builder; public final fun commonName (Ljava/lang/String;)Lokhttp3/tls/HeldCertificate$Builder; public final fun duration (JLjava/util/concurrent/TimeUnit;)Lokhttp3/tls/HeldCertificate$Builder; public final fun ecdsa256 ()Lokhttp3/tls/HeldCertificate$Builder; public final fun keyPair (Ljava/security/KeyPair;)Lokhttp3/tls/HeldCertificate$Builder;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Feb 26 19:17:33 UTC 2022 - 3.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractSortedMultiset.java
*/ package com.google.common.collect; import static com.google.common.base.Preconditions.checkNotNull; import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.concurrent.LazyInit; import com.google.j2objc.annotations.WeakOuter; import java.util.Comparator; import java.util.Iterator; import java.util.NavigableSet; import org.jspecify.annotations.Nullable; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 4.5K 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}. */ @GwtCompatible
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Dec 30 18:44:22 UTC 2024 - 2.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.25.md
- Update kube-apiserver's priority & fairness work estimator such that 'max seats' is MIN(0.15 x nominalCL, nominalCL / handSize) This fixes a bug where clients with requests using hand size x max seats greater than the nominal concurrency limit can starve other requests in the same priority level. ([#118601](https://github.com/kubernetes/kubernetes/pull/118601), [@andrewsykim](https://github.com/andrewsykim)) [SIG API Machinery]
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Mon May 06 09:23:20 UTC 2024 - 419.1K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
import java.security.SecureRandom import java.security.Security import java.security.cert.Certificate import java.security.cert.CertificateException import java.security.cert.X509Certificate import java.util.concurrent.atomic.AtomicInteger import java.util.logging.Handler import java.util.logging.Level import java.util.logging.LogRecord import java.util.logging.Logger import javax.net.ssl.HostnameVerifier
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 14:12:28 UTC 2025 - 29K 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)