Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 85 for unblocking (0.18 sec)

  1. guava/src/com/google/common/cache/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  2. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

        assumeTrue(Build.VERSION.SDK_INT >= 23)
    
        val request = Request.Builder().url("http://squareup.com/robots.txt").build()
    
        try {
          client.newCall(request).execute()
          fail<Any>("expected cleartext blocking")
        } catch (_: java.net.UnknownServiceException) {
        }
      }
    
      data class HowsMySslResults(
        val unknown_cipher_suite_supported: Boolean,
        val beast_vuln: Boolean,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 27K bytes
    - Viewed (1)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        val pooled1 = planReusePooledConnection()
        if (pooled1 != null) return pooled1
    
        // Attempt a deferred plan before new routes.
        if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
    
        // Do blocking calls to plan a route for a new connection.
        val connect = planConnect()
    
        // Now that we have a set of IP addresses, make another attempt at getting a connection from
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  4. docs/en/docs/async.md

    !!! warning
        You can probably skip this.
    
        These are very technical details of how **FastAPI** works underneath.
    
        If you have quite some technical knowledge (coroutines, threads, blocking, etc.) and are curious about how FastAPI handles `async def` vs normal `def`, go ahead.
    
    ### Path operation functions
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 23K bytes
    - Viewed (0)
  5. internal/ioutil/ioutil.go

    			<-t.C
    		}
    		return r.err
    	case <-t.C:
    		return context.DeadlineExceeded
    	}
    }
    
    // NewDeadlineWriter wraps a writer to make it respect given deadline
    // value per Write(). If there is a blocking write, the returned Writer
    // will return whenever the timer hits (the return values are n=0
    // and err=context.DeadlineExceeded.)
    func NewDeadlineWriter(w io.WriteCloser, timeout time.Duration) io.WriteCloser {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  6. src/builtin/builtin.go

    // never the receiver, and has the effect of shutting down the channel after
    // the last sent value is received. After the last value has been received
    // from a closed channel c, any receive from c will succeed without
    // blocking, returning the zero value for the channel element. The form
    //
    //	x, ok := <-c
    //
    // will also set ok to false for a closed and empty channel.
    func close(c chan<- Type)
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  7. cmd/admin-heal-ops.go

    	return jbytes, ErrNone
    }
    
    // healSource denotes single entity and heal option.
    type healSource struct {
    	bucket    string
    	object    string
    	versionID string
    	noWait    bool             // a non blocking call, if task queue is full return right away.
    	opts      *madmin.HealOpts // optional heal option overrides default setting
    }
    
    // healSequence - state for each heal sequence initiated on the
    // server.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  8. internal/config/notify/help.go

    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpNoWait,
    			Description: "non-blocking message delivery when set to 'on', default is 'off'",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpInternal,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  9. tensorflow/c/eager/c_api_experimental.h

      int version = TFE_CUSTOM_DEVICE_VERSION;
    
      // Computes the rank of the tensor handle.
      //
      // Shapes are specified via callbacks because retrieving the shape of a tensor
      // is a blocking operation for async eager; custom devices should avoid
      // retrieving shapes of tensors they wrap until the custom device tensor's
      // shape is explicitly requested where possible.
    C
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Wed Feb 21 22:37:46 GMT 2024
    - 39.5K bytes
    - Viewed (0)
  10. docs/de/docs/async.md

        Dies sind sehr technische Details darüber, wie **FastAPI** unter der Haube funktioniert.
    
        Wenn Sie über gute technische Kenntnisse verfügen (Coroutinen, Threads, Blocking, usw.) und neugierig sind, wie FastAPI mit `async def`s im Vergleich zu normalen `def`s umgeht, fahren Sie fort.
    
    ### Pfadoperation-Funktionen
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Sat Mar 30 18:06:16 GMT 2024
    - 26.6K bytes
    - Viewed (0)
Back to top