Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1271 - 1280 of 1,335 for concurrent (0.58 seconds)

  1. android/guava/src/com/google/common/escape/CharEscaper.java

     * resulting XML document is parsed, the parser API will return this text as the original literal
     * string {@code "Foo<Bar>"}.
     *
     * <p>A {@code CharEscaper} instance is required to be stateless, and safe when used concurrently by
     * multiple threads.
     *
     * <p>Popular escapers are defined as constants in classes like {@link
     * com.google.common.html.HtmlEscapers} and {@link com.google.common.xml.XmlEscapers}. To create
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 13 15:45:16 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  2. internal/s3select/json/preader.go

    	"sync"
    
    	"github.com/minio/minio/internal/bpool"
    	"github.com/minio/minio/internal/s3select/jstream"
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // PReader - JSON record reader for S3Select.
    // Operates concurrently on line-delimited JSON.
    type PReader struct {
    	args        *ReaderArgs
    	readCloser  io.ReadCloser             // raw input
    	buf         *bufio.Reader             // input to the splitter
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  3. pyproject.toml

        "docs_src/",
        "scripts/",
        # For a test
        "docs/en/docs/img/favicon.png",
    ]
    
    [tool.mypy]
    plugins = ["pydantic.mypy"]
    strict = true
    
    [[tool.mypy.overrides]]
    module = "fastapi.concurrency"
    warn_unused_ignores = false
    ignore_missing_imports = true
    
    [[tool.mypy.overrides]]
    module = "fastapi.tests.*"
    ignore_missing_imports = true
    check_untyped_defs = true
    
    [[tool.mypy.overrides]]
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Mar 23 12:36:49 GMT 2026
    - 10.3K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt

       * [RequestBody.writeTo] after that method returns. For duplex requests bodies that condition is
       * lifted. Such writes occur on an application-provided thread and may occur concurrently with
       * reads of the [ResponseBody]. For duplex request bodies, [writeTo] should return
       * quickly, possibly by handing off the provided request body to another thread to perform
       * writing.
       *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 14:16:29 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  5. docs/en/docs/deployment/manually.md

    /// tip
    
    By adding the `standard`, Uvicorn will install and use some recommended extra dependencies.
    
    That including `uvloop`, the high-performance drop-in replacement for `asyncio`, that provides the big concurrency performance boost.
    
    When you install FastAPI with something like `pip install "fastapi[standard]"` you already get `uvicorn[standard]` as well.
    
    ///
    
    ## Run the Server Program { #run-the-server-program }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  6. tests/test_dependency_wrapped.py

    import inspect
    import sys
    from collections.abc import AsyncGenerator, Generator
    from functools import wraps
    
    import pytest
    from fastapi import Depends, FastAPI
    from fastapi.concurrency import iterate_in_threadpool, run_in_threadpool
    from fastapi.testclient import TestClient
    
    if sys.version_info >= (3, 13):  # pragma: no cover
        from inspect import iscoroutinefunction
    else:  # pragma: no cover
        from asyncio import iscoroutinefunction
    
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 11.2K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb1/util/transport/Transport.java

     * knowledge (provided by a concrete subclass) so that connecting,
     * disconnecting, sending, and receiving can be syncronized
     * properly. Apparatus is provided to send and receive requests
     * concurrently.
     */
    
    public abstract class Transport implements Runnable {
    
        /**
         * Default constructor for Transport.
         */
        public Transport() {
            // Default constructor
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  8. docs/fr/docs/deployment/manually.md

    En ajoutant `standard`, Uvicorn va installer et utiliser quelques dépendances supplémentaires recommandées.
    
    Cela inclut `uvloop`, le remplaçant hautes performances de `asyncio`, qui fournit le gros gain de performance en matière de concurrence.
    
    Lorsque vous installez FastAPI avec quelque chose comme `pip install "fastapi[standard]"`, vous obtenez déjà `uvicorn[standard]` aussi.
    
    ///
    
    ## Exécuter le programme serveur { #run-the-server-program }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  9. .github/workflows/build.yml

          - master
      pull_request:
        types: [opened, labeled, unlabeled, synchronize]
    
    permissions:
      contents: read
    
    env:
      GRADLE_OPTS: "-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false"
    
    concurrency:
      group: ${{ github.workflow }}-${{ github.ref }}
      cancel-in-progress: true
    
    jobs:
      publish:
        runs-on: ubuntu-latest
        if: github.repository == 'square/okhttp' && github.ref == 'refs/heads/master'
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 16:19:02 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  10. tests/prepared_stmt_test.go

    	return err.Error() == "sql: statement is closed"
    }
    
    // TestPreparedStmtConcurrentClose test calling close and executing SQL concurrently
    // this test making sure that the gorm would not get a Segmentation Fault, and the only error cause by this is using a closed Stmt
    func TestPreparedStmtConcurrentClose(t *testing.T) {
    	name := "prepared_stmt_concurrent_close"
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 8K bytes
    - Click Count (0)
Back to Top