Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 653 for threads (0.04 sec)

  1. guava/src/com/google/common/primitives/Shorts.java

       * value in the manner of {@link Number#shortValue}.
       *
       * <p>Elements are copied from the argument collection as if by {@code collection.toArray()}.
       * Calling this method is as thread-safe as calling that method.
       *
       * @param collection a collection of {@code Number} instances
       * @return an array containing the same values as {@code collection}, in the same order, converted
       *     to primitives
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 25.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/graph/Network.java

     * }
     *
     * <p>Instances of {@link ImmutableNetwork} do not implement {@link MutableNetwork} (obviously!) and
     * are contractually guaranteed to be unmodifiable and thread-safe.
     *
     * <p>The Guava User Guide has <a
     * href="https://github.com/google/guava/wiki/GraphsExplained#building-graph-instances">more
     * information on (and examples of) building graphs</a>.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 22:03:02 UTC 2025
    - 22.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/math/StatsAccumulator.java

    import java.util.stream.LongStream;
    
    /**
     * A mutable object which accumulates double values and tracks some basic statistics over all the
     * values added so far. The values may be added singly or in groups. This class is not thread safe.
     *
     * @author Pete Gillin
     * @author Kevin Bourrillion
     * @since 20.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class StatsAccumulator {
      /** Creates a new accumulator. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 16:36:11 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // Give the server time to enact the socket policy if it's one that could happen after the
        // client has received the response.
        Thread.sleep(500)
        val response2 = getResponse(newRequest("/b"))
        response1.body
          .source()
          .timeout()
          .timeout(100, TimeUnit.MILLISECONDS)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  5. docs/smb3-features/01-smb3-lease-design.md

    }
    ```
    
    ## 9. Performance Considerations
    
    ### 9.1 Memory Management
    - Lease entries should be evicted based on LRU when max leases reached
    - Implement periodic cleanup of expired leases
    
    ### 9.2 Thread Safety
    - Use concurrent data structures for lease storage
    - Minimize lock contention in hot paths
    - Async handling of lease breaks
    
    ### 9.3 Network Efficiency
    - Batch lease requests when possible
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 22K bytes
    - Viewed (0)
  6. docs/recipes.md

              }
    
              System.out.println(response.body().string());
            }
          }
        ```
    
    ### Asynchronous Get ([.kt][AsynchronousGetKotlin], [.java][AsynchronousGetJava])
    
    Download a file on a worker thread, and get called back when the response is readable. The callback is made after the response headers are ready. Reading the response body may still block. OkHttp doesn't currently offer asynchronous APIs to receive a response body in parts.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  7. tensorflow/c/c_api.h

    // --------------------------------------------------------------------------
    // The new graph construction API, still under development.
    
    // Represents a computation graph.  Graphs may be shared between sessions.
    // Graphs are thread-safe when used as directed below.
    typedef struct TF_Graph TF_Graph;
    
    // Return a new graph object.
    TF_CAPI_EXPORT extern TF_Graph* TF_NewGraph(void);
    
    // Destroy an options object. Graph will be deleted once no more
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
  8. docs/bucket/replication/README.md

    ![put](https://raw.githubusercontent.com/minio/minio/master/docs/bucket/replication/PUT_bucket_replication.png)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  9. CONTRIBUTING.md

    contributions, often because we probably won't get to them right now. If you
    decide to start on an issue, leave a comment so that other people know that
    you're working on it. If you want to help out, but not alone, use the issue
    comment thread to coordinate.
    
    ### Contribution guidelines and standards
    
    Before sending your pull request for
    [review](https://github.com/tensorflow/tensorflow/pulls),
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Sat Jan 11 04:47:59 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  10. statement.go

    	}
    }
    
    // BuildCondition build condition
    func (stmt *Statement) BuildCondition(query interface{}, args ...interface{}) []clause.Expression {
    	if s, ok := query.(string); ok {
    		// if it is a number, then treats it as primary key
    		if _, err := strconv.Atoi(s); err != nil {
    			if s == "" && len(args) == 0 {
    				return nil
    			}
    
    			if len(args) == 0 || (len(args) > 0 && strings.Contains(s, "?")) {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Sep 04 13:13:16 UTC 2025
    - 20.8K bytes
    - Viewed (0)
Back to top