Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 120 for asynchronous (0.07 sec)

  1. docs/ko/docs/async.md

    ```Python hl_lines="1"
    async def get_burgers(number: int):
        # Do some asynchronous stuff to create the burgers
        return burgers
    ```
    
    ...`def`를 사용하는 대신:
    
    ```Python hl_lines="2"
    # This is not asynchronous
    def get_sequential_burgers(number: int):
        # Do some sequential stuff to create the burgers
        return burgers
    ```
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  2. docs/bigdata/README.md

    ```
    cat ${HADOOP_CONF_DIR}/core-site.xml | kv-pairify | grep "mapred"
    
    mapred.maxthreads.generate.mapoutput=2 # Num threads to write map outputs
    mapred.maxthreads.partition.closer=0 # Asynchronous map flushers
    mapreduce.fileoutputcommitter.algorithm.version=2 # Use the latest committer version
    mapreduce.job.reduce.slowstart.completedmaps=0.99 # 99% map, then reduce
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

      val directory: Path,
      private val appVersion: Int,
      internal val valueCount: Int,
      /** Returns the maximum number of bytes that this cache should use to store its data. */
      maxSize: Long,
      /** Used for asynchronous journal rebuilds. */
      taskRunner: TaskRunner,
    ) : Closeable,
      Flushable,
      Lockable {
      internal val fileSystem: FileSystem =
        object : ForwardingFileSystem(fileSystem) {
          override fun sink(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

      internal var nextStreamId = if (builder.client) 3 else 2
    
      private var isShutdown = false
    
      /** For scheduling everything asynchronous. */
      private val taskRunner = builder.taskRunner
    
      /** Asynchronously writes frames to the outgoing socket. */
      private val writerQueue = taskRunner.newQueue()
    
      /** Ensures push promise callbacks events are sent in order per stream. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  5. docs/de/docs/index.md

    ## Installation
    
    <div class="termy">
    
    ```console
    $ pip install fastapi
    
    ---> 100%
    ```
    
    </div>
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 21.1K bytes
    - Viewed (0)
  6. docs/bucket/notifications/README.md

    streaming                         (on|off)    set to 'on', to use streaming NATS server
    streaming_async                   (on|off)    set to 'on', to enable asynchronous publish
    streaming_max_pub_acks_in_flight  (number)    number of messages to publish without waiting for ACKs
    streaming_cluster_id              (string)    unique ID for NATS streaming cluster
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  7. docs/uk/docs/alternatives.md

    ///
    
    ### <a href="https://www.starlette.io/" class="external-link" target="_blank">Starlette</a>
    
    Starlette — це легкий фреймворк/набір інструментів <abbr title="The new standard for build asynchronous Python web">ASGI</abbr>, який ідеально підходить для створення високопродуктивних asyncio сервісів.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 38.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/Futures.java

     * article on <a href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code
     * ListenableFuture}</a>.
     *
     * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of
     * asynchronous operations. You can chain them together manually with calls to methods like {@link
     * Futures#transform(ListenableFuture, Function, Executor) Futures.transform}, but you will often
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

          this.routeDatabase = okHttpClient.routeDatabase
          this.taskRunner = okHttpClient.taskRunner
        }
    
        /**
         * Sets the dispatcher used to set policy and execute asynchronous requests. Must not be null.
         */
        fun dispatcher(dispatcher: Dispatcher) =
          apply {
            this.dispatcher = dispatcher
          }
    
        /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2.go

    			err = x.setIdx(i, *ver)
    		default:
    			x.versions = append(x.versions[:i], x.versions[i+1:]...)
    			// if uv has tiered content we add a
    			// free-version to track it for
    			// asynchronous deletion via scanner.
    			if freeVersion, toFree := ver.ObjectV2.InitFreeVersion(fi); toFree {
    				err = x.addVersion(freeVersion)
    			}
    		}
    
    		if fi.Deleted {
    			err = x.addVersion(ventry)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
Back to top