Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 198 for spool (0.04 sec)

  1. docs/contribute/concurrency.md

    ## Connection Pool
    
    A primary responsibility for any HTTP client is to efficiently manage network connections. Creating and establishing new connections require a fair amount of overhead and added latency. OkHttp will make every effort to reuse existing connections to avoid this overhead and added latency.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. docs/distributed/CONFIG.md

    ```
    
    ### Things to know
    
    - Fields such as `version` and `pools` are mandatory, however all other fields are optional.
    - Each pool expects a minimum of 2 nodes per pool, and unique non-repeating hosts for each argument.
    - Each pool expects each host in this pool has the same number of drives specified as any other host.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 25 02:30:18 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. ci/official/containers/ml_build/builder.devtoolset/build_devtoolset.sh

      wget "http://old-releases.ubuntu.com/ubuntu/pool/main/e/eglibc/libc6_2.12.1-0ubuntu6_amd64.deb" && \
          unar "libc6_2.12.1-0ubuntu6_amd64.deb" && \
          tar -C "${TARGET}" -xvzf "libc6_2.12.1-0ubuntu6_amd64/data.tar.gz" && \
          rm -rf "libc6_2.12.1-0ubuntu6_amd64.deb" "libc6_2.12.1-0ubuntu6_amd64"
      # Download binary glibc 2.12 development library release.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Sep 24 20:45:58 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. cmd/metacache-set_gen.go

    		case "StopDiskAtLimit":
    			z.StopDiskAtLimit, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "StopDiskAtLimit")
    				return
    			}
    		case "pool":
    			z.pool, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "pool")
    				return
    			}
    		case "set":
    			z.set, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "set")
    				return
    			}
    		default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:23:12 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java

            final ForkJoinPool pool = new ForkJoinPool(10);
            for (int i = 0; i < 1000; i++) {
                pool.execute(() -> {
                    assertEquals(result, crawlingInfoHelper.generateId(dataMap));
                    counter.incrementAndGet();
                });
            }
            pool.shutdown();
            pool.awaitTermination(10, TimeUnit.SECONDS);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. internal/jwt/parser.go

    	return HashBorrower{pool: &s.HasherPool, borrowed: make([]hash.Hash, 0, 2)}
    }
    
    // HashBorrower keeps track of borrowed hashers and allows to return them all.
    type HashBorrower struct {
    	pool     *sync.Pool
    	borrowed []hash.Hash
    }
    
    // Borrow a single hasher.
    func (h *HashBorrower) Borrow() hash.Hash {
    	hasher := h.pool.Get().(hash.Hash)
    	h.borrowed = append(h.borrowed, hasher)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  7. cmd/metacache-marker.go

    				continue
    			}
    		case "id":
    			o.ID = kv[1]
    		case "return":
    			o.ID = mustGetUUID()
    			o.Create = true
    		case "p": // pool
    			v, err := strconv.ParseInt(kv[1], 10, 64)
    			if err != nil {
    				o.ID = mustGetUUID()
    				o.Create = true
    				continue
    			}
    			o.pool = int(v)
    		case "s": // set
    			v, err := strconv.ParseInt(kv[1], 10, 64)
    			if err != nil {
    				o.ID = mustGetUUID()
    				o.Create = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  8. fastapi/concurrency.py

    ) -> 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
        # since we're creating a new limiter for each call, any non-zero limit
        # works (1 is arbitrary)
        exit_limiter = CapacityLimiter(1)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Dec 25 17:57:35 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

       *     be unique to the built instance of the ThreadFactory and will be assigned sequentially. For
       *     example, {@code "rpc-pool-%d"} will generate thread names like {@code "rpc-pool-0"}, {@code
       *     "rpc-pool-1"}, {@code "rpc-pool-2"}, etc.
       * @return this for the builder pattern
       */
      @CanIgnoreReturnValue
      public ThreadFactoryBuilder setNameFormat(String nameFormat) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:50:54 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

      var uriPort: Int = 1
    
      fun newConnection(
        pool: RealConnectionPool,
        route: Route,
        idleAtNanos: Long = Long.MAX_VALUE,
        taskRunner: TaskRunner = this.taskRunner,
      ): RealConnection {
        val result =
          RealConnection.newTestConnection(
            taskRunner = taskRunner,
            connectionPool = pool,
            route = route,
            socket = Socket(),
            idleAtNs = idleAtNanos,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top