Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 477 for Thread (0.05 seconds)

  1. guava/src/com/google/common/collect/ArrayTable.java

     * an {@code ArrayTable} concurrently and one of the threads modifies its value, there is no
     * guarantee that the new value will be fully visible to the other threads. To guarantee that
     * modifications are visible, synchronize access to the table. Unlike other {@code Table}
     * implementations, synchronization is unnecessary between a thread that writes to one cell and a
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 26.9K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        val response = call.execute()
        val inputStream = response.body.byteStream()
        assertThat(inputStream.read()).isEqualTo('A'.code)
        assertThat(inputStream.read()).isEqualTo('B'.code)
        assertThat(inputStream.read()).isEqualTo('C'.code)
        assertThat(inputStream.read()).isEqualTo(-1)
        assertThat(inputStream.read()).isEqualTo(-1)
        inputStream.close()
      }
    
      @Test
      fun readResponseHeaderTimeout() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 67.4K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/ArrayTable.java

     * an {@code ArrayTable} concurrently and one of the threads modifies its value, there is no
     * guarantee that the new value will be fully visible to the other threads. To guarantee that
     * modifications are visible, synchronize access to the table. Unlike other {@code Table}
     * implementations, synchronization is unnecessary between a thread that writes to one cell and a
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Aug 13 19:39:21 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

    /**
     * Factory for [calls][Call], which can be used to send HTTP requests and read their responses.
     *
     * ## OkHttpClients Should Be Shared
     *
     * OkHttp performs best when you create a single `OkHttpClient` instance and reuse it for all of
     * your HTTP calls. This is because each client holds its own connection pool and thread pools.
     * Reusing connections and threads reduces latency and saves memory. Conversely, creating a client
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  5. docs/en/docs/tutorial/sql-databases.md

    ### Read Heroes { #read-heroes }
    
    We can **read** `Hero`s from the database using a `select()`. We can include a `limit` and `offset` to paginate the results.
    
    {* ../../docs_src/sql_databases/tutorial001_an_py310.py ln[48:55] hl[51:52,54] *}
    
    ### Read One Hero { #read-one-hero }
    
    We can **read** a single `Hero`.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 02 05:06:56 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  6. docs/de/docs/tutorial/sql-databases.md

    Die Verwendung von `check_same_thread=False` erlaubt FastAPI, dieselbe SQLite-Datenbank in verschiedenen Threads zu verwenden. Dies ist notwendig, da **ein einzelner <abbr title="Request – Anfrage: Daten, die der Client zum Server sendet">Request</abbr>** **mehr als einen Thread** verwenden könnte (zum Beispiel in Abhängigkeiten).
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 02 17:32:56 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  7. compat/maven-embedder/src/main/java/org/apache/maven/cli/CLIManager.java

                    .optionalArg(true)
                    .desc("Encrypt server password")
                    .build());
            options.addOption(Option.builder(THREADS)
                    .longOpt("threads")
                    .hasArg()
                    .desc("Thread count, for instance 4 (int) or 2C/2.5C (int/float) where C is core multiplied")
                    .build());
            options.addOption(Option.builder(BUILDER)
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Aug 06 04:56:48 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  8. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        //
        // TODO(user): Consider using
        // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage()
        //
        // TODO(user): Consider scaling by number of mutator threads,
        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool-decom.go

    	fn := z.decommissionCancelers[idx]
    	if fn == nil {
    		// canceling a decommission before it started return an error.
    		return errDecommissionNotStarted
    	}
    
    	defer fn() // cancel any active thread.
    
    	if z.poolMeta.DecommissionCancel(idx) {
    		if err = z.poolMeta.save(ctx, z.serverPools); err != nil {
    			return err
    		}
    		globalNotificationSys.ReloadPoolMeta(ctx)
    	}
    
    	return nil
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  10. guava-testlib/src/com/google/common/testing/GcFinalization.java

        //
        // TODO(user): Consider using
        // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage()
        //
        // TODO(user): Consider scaling by number of mutator threads,
        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 11.5K bytes
    - Click Count (0)
Back to Top