Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 93 for unblocking (0.35 sec)

  1. fastapi/datastructures.py

        Define it as a *path operation function* (or dependency) parameter.
    
        If you are using a regular `def` function, you can use the `upload_file.file`
        attribute to access the raw standard Python file (blocking, not async), useful and
        needed for non-async code.
    
        Read more about it in the
        [FastAPI docs for Request Files](https://fastapi.tiangolo.com/tutorial/request-files/).
    
        ## Example
    
        ```python
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. docs/changelogs/changelog_1x.md

     * Fix bug where the Content-Length header was not always dropped when
       following a redirect from a POST to a GET.
     * Implement basic support for `Thread.interrupt()`. OkHttp now checks
       for an interruption before doing a blocking call. If it is interrupted,
       it throws an `InterruptedIOException`.
    
    ## Version 1.5.2
    
    _2014-03-17_
    
     * Fix bug where deleting a file that was absent from the `HttpResponseCache`
       caused an IOException.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  3. RELEASE_BRANCHES.md

    merged in before and after the first public release.
    
    # Feature Freeze
    
    One week before a release, the release branch goes into a state of code freeze. At this point only critical release
    blocking bugs are addressed. Additional changes that are targeted for new features and capabilities will not be merged.
    
    ## Features requiring API changes
    
    If a PR change requires an API change
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Sep 16 21:14:17 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

       *
       * <p>Currently, this method is invoked while holding a lock. If an implementation of this method
       * blocks, it can prevent this service from changing state. If you need to performing a blocking
       * operation in order to trigger shutdown, consider instead registering a listener and
       * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  5. docs/en/docs/async.md

    ### Other forms of asynchronous code
    
    This style of using `async` and `await` is relatively new in the language.
    
    But it makes working with asynchronous code a lot easier.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

            } finally {
              taskRunner.lock.withLock {
                activeThreads--
                startNextTask()
              }
            }
          }
        }
      }
    
      /**
       * This blocking queue hooks into a fake clock rather than using regular JVM timing for functions
       * like [poll]. It is only usable within task faker tasks.
       */
      private inner class TaskFakerBlockingQueue<T>(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3
    
    import okio.ByteString
    
    /**
     * A non-blocking interface to a web socket. Use the [factory][WebSocket.Factory] to create
     * instances; usually this is [OkHttpClient].
     *
     * ## Web Socket Lifecycle
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. cmd/main.go

    // Main main for minio server.
    func Main(args []string) {
    	// Set the minio app name.
    	appName := filepath.Base(args[0])
    
    	if debugNoExit {
    		freeze := func(_ int) {
    			// Infinite blocking op
    			<-make(chan struct{})
    		}
    
    		// Override the logger os.Exit()
    		logger.ExitFunc = freeze
    
    		defer func() {
    			if err := recover(); err != nil {
    				fmt.Println("panic:", err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:59:48 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. internal/grid/muxserver.go

    			wg.Wait()
    			defer xioutil.SafeClose(handlerIn)
    			m.handleInbound(c, inbound, handlerIn)
    		}(m.inbound)
    	}
    	// Fill outbound block.
    	// Each token represents a message that can be sent to the client without blocking.
    	// The client will refill the tokens as they confirm delivery of the messages.
    	for i := 0; i < outboundCap; i++ {
    		m.outBlock <- struct{}{}
    	}
    
    	// Handler goroutine.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/cache/AbstractCache.java

        /**
         * Records cache misses. This should be called when a cache request returns a value that was not
         * found in the cache. This method should be called by the loading thread, as well as by threads
         * blocking on the load. Multiple concurrent calls to {@link Cache} lookup methods with the same
         * key on an absent value should result in a single call to either {@code recordLoadSuccess} or
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 9.1K bytes
    - Viewed (0)
Back to top