Search Options

Results per page
Sort
Preferred Languages
Advance

Results 681 - 690 of 1,022 for concurrency (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top