Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for Thread (0.05 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

                    }
                  });
          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  2. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

                        throw new IllegalArgumentException("Invalid threads core multiplier value: '" + threadConfiguration
                                + "'. Value must be positive.");
                    }
    
                    int procs = Runtime.getRuntime().availableProcessors();
                    int threads = (int) (coreMultiplier * procs);
                    return threads == 0 ? 1 : threads;
                } else {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/cache/CacheBuilder.java

       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
       * higher value than you need can waste space and time, and a significantly lower value can lead
       * to thread contention. But overestimates and underestimates within an order of magnitude do not
       * usually have much noticeable impact. A value of one permits only one thread to modify the cache
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/EventListenerTest.kt

        }
    
        override fun writeTo(sink: BufferedSink) {
          try {
            var i = 0
            while (i < contentLength()) {
              sink.write(chunk!!)
              sink.flush()
              Thread.sleep(100)
              i += chunk.size
            }
          } catch (e: IOException) {
            ioe = e
          } catch (e: InterruptedException) {
            throw RuntimeException(e)
          }
        }
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  5. android/guava/src/com/google/common/collect/Multimaps.java

        for (Map.Entry<? extends V, ? extends K> entry : source.entries()) {
          dest.put(entry.getValue(), entry.getKey());
        }
        return dest;
      }
    
      /**
       * Returns a synchronized (thread-safe) multimap backed by the specified multimap. In order to
       * guarantee serial access, it is critical that <b>all</b> access to the backing multimap is
       * accomplished through the returned multimap.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTransportImpl.java

            /*
             * Note the Transport thread isn't running yet so we can
             * read from the socket here.
             */
            try {
                this.socket.setSoTimeout(this.transportContext.getConfig().getConnTimeout());
                if ( peekKey() == null ) /* try to read header */
                    throw new IOException("transport closed in negotiate");
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Sets.java

      }
    
      /**
       * Creates a thread-safe set backed by a hash map. The set is backed by a {@link
       * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees.
       *
       * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The
       * set is serializable.
       *
       * @return a new, empty thread-safe {@code Set}
       * @since 15.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/cache/CacheBuilder.java

       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
       * higher value than you need can waste space and time, and a significantly lower value can lead
       * to thread contention. But overestimates and underestimates within an order of magnitude do not
       * usually have much noticeable impact. A value of one permits only one thread to modify the cache
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  9. okhttp/src/main/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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  10. okhttp/src/test/java/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()
      }
    
      @ParameterizedTest
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
Back to top