Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 195 for race (0.02 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/TagsTest.kt

      fun computeIfAbsentWhenDifferentKeyRaceLostDuringCompute() {
        val tags = EmptyTags
        val atomicTags = AtomicReference<Tags>(tags)
        val result =
          atomicTags.computeIfAbsent(String::class) {
            // 'Race' by making another computeIfAbsent call. In practice this would be another thread.
            assertThat(atomicTags.computeIfAbsent(Integer::class) { 5 as Integer }).isEqualTo(5)
            "a"
          }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 24 11:37:46 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  2. impl/maven-core/src/test/java/org/apache/maven/internal/MultilineMessageHelperTest.java

            msgs.add("* An aggregator Mojo is already executing in parallel build,    *");
            msgs.add("* but aggregator Mojos require exclusive access to reactor to   *");
            msgs.add("* prevent race conditions. This mojo execution will be blocked  *");
            msgs.add("* until the aggregator work is done.                            *");
            msgs.add("*****************************************************************");
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/io/RecursiveDeleteOption.java

    @J2ObjCIncompatible // java.nio.file
    public enum RecursiveDeleteOption {
      /**
       * Specifies that the recursive delete should not throw an exception when it can't be guaranteed
       * that it can be done securely, without vulnerability to race conditions (i.e. when the file
       * system does not support {@link SecureDirectoryStream}).
       *
       * <p><b>Warning:</b> On a file system that supports symbolic links, it is possible for an
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

          "plan 1 TLS connected",
        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test performs two races:
       *
       *  * The first race is between plan0 and plan1, with a 250 ms head start for plan0.
       *  * The second race is between plan2 and plan3, with a 250 ms head start for plan2.
       *
       * We get plan0 and plan1 from the route planner.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  5. docs/features/connections.md

     * Don't start a new attempt until 250 ms after the most recent attempt was started.
     * Keep whichever TCP connection succeeds first and cancel all the others.
     * Race TCP only. Only attempt a TLS handshake on the winning TCP connection.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  6. docs/features/events.md

        printEvent("callStart");
      }
    
      @Override public void callEnd(Call call) {
        printEvent("callEnd");
      }
    
      ...
    }
    ```
    
    We can use this listener to race a pair of concurrent HTTP requests:
    
    ```java
    Request washingtonPostRequest = new Request.Builder()
        .url("https://www.washingtonpost.com/")
        .build();
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 7.7K bytes
    - Viewed (0)
  7. fastapi/concurrency.py

    
    @asynccontextmanager
    async def contextmanager_in_threadpool(
        cm: AbstractContextManager[_T],
    ) -> AsyncGenerator[_T, None]:
        # blocking __exit__ from running waiting on a free thread
        # can create race conditions/deadlocks if the context manager itself
        # has its own internal pool (e.g. a database connection pool)
        # to avoid this we let __exit__ run without a capacity limit
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 21:25:59 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  8. .github/workflows/go-lint.yml

            run: |
              sudo apt install jq -y
              sudo sysctl net.ipv6.conf.all.disable_ipv6=0
              sudo sysctl net.ipv6.conf.default.disable_ipv6=0
              make
              make test
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 1010 bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        assertThrows(IllegalArgumentException.class, () -> multiset.add(KEY, COUNT_TO_ADD));
      }
    
      /**
       * Simulate some of the races that can happen on add. We can't easily simulate the race that
       * happens when an {@link AtomicInteger#compareAndSet} fails, but we can simulate the case where
       * the putIfAbsent returns a non-null value, and the case where the replace() of an observed zero
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 16.3K bytes
    - Viewed (0)
  10. docs/bucket/replication/test_del_marker_proxying.sh

    	pkill -9 minio || sudo pkill -9 minio
    	rm -rf /tmp/sitea
    	rm -rf /tmp/siteb
    	echo "done"
    }
    
    cleanup
    
    export MINIO_CI_CD=1
    export MINIO_BROWSER=off
    
    make install-race
    
    # Start MinIO instances
    echo -n "Starting MinIO instances ..."
    minio server --address 127.0.0.1:9001 --console-address ":10000" "http://127.0.0.1:9001/tmp/sitea/data/disterasure/xl{1...4}" \
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 2.2K bytes
    - Viewed (0)
Back to top