Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 761 - 770 of 1,334 for concurrent1 (0.06 seconds)

  1. internal/bucket/lifecycle/noncurrentversion.go

    	}
    	*n = NoncurrentVersionTransition(val)
    	n.set = true
    	return nil
    }
    
    // IsNull returns true if NoncurrentTransition doesn't refer to any storage-class.
    // Note: It supports immediate transition, i.e zero noncurrent days.
    func (n NoncurrentVersionTransition) IsNull() bool {
    	return n.StorageClass == ""
    }
    
    // Validate returns an error with wrong value
    func (n NoncurrentVersionTransition) Validate() error {
    	if !n.set {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Dec 14 17:41:44 GMT 2021
    - 5.3K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

    import java.net.SocketTimeoutException
    import java.time.Duration
    import java.util.Arrays
    import java.util.Collections
    import java.util.Random
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicInteger
    import kotlin.test.assertFailsWith
    import mockwebserver3.Dispatcher
    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
    - 35.5K bytes
    - Click Count (0)
  3. mockwebserver-junit5/src/test/java/mockwebserver3/junit5/StartStopTest.kt

     * limitations under the License.
     */
    package mockwebserver3.junit5
    
    import assertk.assertThat
    import assertk.assertions.isFalse
    import assertk.assertions.isTrue
    import java.util.concurrent.CopyOnWriteArrayList
    import mockwebserver3.Dispatcher
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.RecordedRequest
    import org.junit.jupiter.api.Test
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 11:13:17 GMT 2025
    - 3.3K bytes
    - Click Count (1)
  4. android/guava/src/com/google/common/cache/RemovalCause.java

     * the License.
     */
    
    package com.google.common.cache;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.concurrent.ConcurrentMap;
    
    /**
     * The reason why a cached entry was removed.
     *
     * @author Charles Fry
     * @since 10.0
     */
    @GwtCompatible
    public enum RemovalCause {
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  5. impl/maven-core/src/main/java/org/apache/maven/execution/DefaultMavenExecutionResult.java

     * under the License.
     */
    package org.apache.maven.execution;
    
    import java.util.Collections;
    import java.util.IdentityHashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.CopyOnWriteArrayList;
    
    import org.apache.maven.project.DependencyResolutionResult;
    import org.apache.maven.project.MavenProject;
    
    public class DefaultMavenExecutionResult implements MavenExecutionResult {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  6. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/PluginLifecycle.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.lifecycle.internal.concurrent;
    
    import java.util.Collection;
    import java.util.Collections;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.Lifecycle;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.6K bytes
    - Click Count (0)
  7. CONTRIBUTORS

    mirroring out changes from our internal repo.
    
    This files serves mainly to credit people who have not received proper credit
    in the Git history.
    
    Doug Lea, author of some concurrency libraries
    
    Joshua O'Madadhain (@jrtom), author of some common.graph commits beyond those
    that are already attributed to him in the Git history:
    https://github.com/google/guava/commit/909c593c61a656c2d70f0f9bd1cb0e5cdf43a556
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Oct 09 21:14:06 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertThat(map.entryHelper)
            .isInstanceOf(MapMakerInternalMap.StrongKeyStrongValueEntry.Helper.class);
    
        assertEquals(4, map.concurrencyLevel);
    
        // concurrency level
        assertThat(map.segments).hasLength(4);
        // initial capacity / concurrency level
        assertEquals(16 / map.segments.length, map.segments[0].table.length());
      }
    
      public void testSetKeyEquivalence() {
        Equivalence<Object> testEquivalence =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 36K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertThat(map.entryHelper)
            .isInstanceOf(MapMakerInternalMap.StrongKeyStrongValueEntry.Helper.class);
    
        assertEquals(4, map.concurrencyLevel);
    
        // concurrency level
        assertThat(map.segments).hasLength(4);
        // initial capacity / concurrency level
        assertEquals(16 / map.segments.length, map.segments[0].table.length());
      }
    
      public void testSetKeyEquivalence() {
        Equivalence<Object> testEquivalence =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 36K bytes
    - Click Count (0)
  10. .github/workflows/upgrade-ci-cd.yaml

    name: Upgrade old version tests
    
    on:
      pull_request:
        branches:
          - master
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      build:
        name: Go ${{ matrix.go-version }} on ${{ matrix.os }}
        runs-on: ${{ matrix.os }}
        strategy:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 729 bytes
    - Click Count (0)
Back to Top