Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for poolId (0.03 sec)

  1. CHANGELOG.md

     *  New: `ConnectionPool.setPolicy()` configures a minimum connection pool size for a target
        address. Use this to proactively open HTTP connections.
    
        Connections opened to fulfill this policy are subject to the connection pool's
        `keepAliveDuration` but do not count against the pool-wide `maxIdleConnections` limit.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  2. fess-crawler/pom.xml

    			<artifactId>commons-net</artifactId>
    			<version>${commons.net.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.apache.commons</groupId>
    			<artifactId>commons-pool2</artifactId>
    			<version>${commons.pool2.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>com.google.guava</groupId>
    			<artifactId>guava</artifactId>
    			<version>${guava.version}</version>
    		</dependency>
    		<dependency>
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Dec 20 06:34:36 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/InternersTest.java

        String not = new String("a");
    
        Interner<String> pool = Interners.newStrongInterner();
        assertSame(canonical, pool.intern(canonical));
        assertSame(canonical, pool.intern(not));
      }
    
      public void testStrong_null() {
        Interner<String> pool = Interners.newStrongInterner();
        assertThrows(NullPointerException.class, () -> pool.intern(null));
      }
    
      public void testStrong_builder() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  4. 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 Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 21:25:59 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
        checkThreadPoolName(thread2, 2);
        assertEquals(
            thread.getName().substring(0, thread.getName().lastIndexOf('-')),
            thread2.getName().substring(0, thread.getName().lastIndexOf('-')));
    
        // Building again should give us a different pool ID.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

        int tasksPerThread = 10;
        int nTasks = nThreads * tasksPerThread;
        ExecutorService pool = newFixedThreadPool(nThreads);
        ImmutableList<String> keys = ImmutableList.of("a", "b", "c");
        try {
          List<Future<int[]>> futures = newArrayListWithExpectedSize(nTasks);
          for (int i = 0; i < nTasks; i++) {
            futures.add(pool.submit(new MutateTask(multiset, keys)));
          }
    
          int[] deltas = new int[3];
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
        checkThreadPoolName(thread2, 2);
        assertEquals(
            thread.getName().substring(0, thread.getName().lastIndexOf('-')),
            thread2.getName().substring(0, thread.getName().lastIndexOf('-')));
    
        // Building again should give us a different pool ID.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  8. scripts/docs.py

            if (lang.is_dir() and lang.name in SUPPORTED_LANGS)
        ]
        cpu_count = os.cpu_count() or 1
        process_pool_size = cpu_count * 4
        typer.echo(f"Using process pool size: {process_pool_size}")
        with Pool(process_pool_size) as p:
            p.map(build_lang, langs)
    
    
    @app.command()
    def update_languages() -> None:
        """
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Dec 21 17:40:17 UTC 2025
    - 16.9K bytes
    - Viewed (0)
  9. docs/es/docs/tutorial/request-files.md

    {* ../../docs_src/request_files/tutorial001_an_py39.py hl[14] *}
    
    Usar `UploadFile` tiene varias ventajas sobre `bytes`:
    
    * No tienes que usar `File()` en el valor por defecto del parámetro.
    * Usa un archivo "spooled":
        * Un archivo almacenado en memoria hasta un límite de tamaño máximo, y después de superar este límite, se almacenará en el disco.
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  10. docs/en/docs/advanced/events.md

    This can be very useful for setting up **resources** that you need to use for the whole app, and that are **shared** among requests, and/or that you need to **clean up** afterwards. For example, a database connection pool, or loading a shared machine learning model.
    
    ## Use Case { #use-case }
    
    Let's start with an example **use case** and then see how to solve it with this.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 7.9K bytes
    - Viewed (0)
Back to top