Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 133 for Concurrency (0.08 seconds)

  1. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

        FakeTicker ticker = new FakeTicker();
        assertThrows(
            IllegalArgumentException.class, () -> ticker.setAutoIncrementStep(-1, NANOSECONDS));
      }
    
      @GwtIncompatible // concurrency
    
      public void testConcurrentAdvance() throws Exception {
        FakeTicker ticker = new FakeTicker();
    
        int numberOfThreads = 64;
        runConcurrentTest(
            numberOfThreads,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. cmd/perf-tests.go

    			Region:    region,
    		})
    		if err != nil {
    			return res, err
    		}
    	}
    
    	var mu sync.Mutex
    	var uploadTimes madmin.TimeDurations
    	wg.Add(opts.concurrency)
    	for i := 0; i < opts.concurrency; i++ {
    		go func(i int) {
    			defer wg.Done()
    			for {
    				t := time.Now()
    				reader := newRandomReader(opts.objectSize)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  3. .github/workflows/helm-lint.yml

    name: Helm Chart linting
    
    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:
      release:
        runs-on: ubuntu-latest
        steps:
          - name: Checkout
            uses: actions/checkout@v4
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jun 09 09:13:09 GMT 2024
    - 551 bytes
    - Click Count (0)
  4. 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 Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Oct 09 21:14:06 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  5. internal/logger/logrotate.go

    	// When FileNameFunc is not specified, DefaultFilenameFunc will be used.
    	FileNameFunc func() string
    
    	// Compress specify if you want the logs to be compressed after rotation.
    	Compress bool
    }
    
    // Writer is a concurrency-safe writer with file rotation.
    type Writer struct {
    	// opts are the configuration options for this Writer
    	opts Options
    
    	// f is the currently open file used for appends.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  6. .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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 729 bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt

       * may be computed. But only one value will be inserted, and that inserted value will be returned
       * to all callers.
       *
       * If computing multiple values is problematic, use an appropriate concurrency mechanism in your
       * [computeIfAbsent] implementation. No locks are held while calling this function.
       */
      fun <T : Any> tag(
        type: KClass<T>,
        computeIfAbsent: () -> T,
      ): T
    
      /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  8. .github/workflows/go.yml

    name: Functional 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 }} - healing
        runs-on: ${{ matrix.os }}
        strategy:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 1.1K bytes
    - Click Count (0)
  9. .github/workflows/go-lint.yml

    name: Linters and 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:
          matrix:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 1010 bytes
    - Click Count (0)
  10. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * @return an unmodifiable version of the input which will not hang the JVM
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) {
        return new Application().getExitingExecutorService(executor);
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
Back to Top