Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 776 for thread (0.32 sec)

  1. android/guava/src/com/google/common/collect/ForwardingMap.java

     * not consistent with {@code equals}.
     *
     * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Kevin Bourrillion
     * @author Jared Levy
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Aug 06 17:32:30 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  2. build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/support/unsafeLazy.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package org.gradle.kotlin.dsl.internal.sharedruntime.support
    
    
    /**
     * Thread unsafe version of [lazy].
     *
     * @see LazyThreadSafetyMode.NONE
     */
    internal
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Sun Oct 01 11:18:48 UTC 2023
    - 867 bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

      private val forbiddenLocks = mutableListOf<Any>()
    
      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                    }
                  });
          expectedKeys.add(s);
        }
    
        computationLatch.countDown();
        // let some computations complete
        while (computedCount.get() < nThreads) {
          Thread.yield();
        }
        cache.invalidateAll();
        tasksFinished.await();
    
        // Check all of the removal notifications we received: they should have had correctly-associated
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        assertThat(inputStream.read()).isEqualTo('A'.code)
        assertThat(inputStream.read()).isEqualTo('B'.code)
        assertThat(inputStream.read()).isEqualTo('C'.code)
        assertThat(inputStream.read()).isEqualTo('D'.code)
        assertThat(inputStream.read()).isEqualTo('E'.code)
        assertThat(inputStream.read()).isEqualTo('F'.code)
        assertThat(inputStream.read()).isEqualTo(-1)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

             */
            public boolean isTeminated() {
                return teminated;
            }
        }
    
        /**
         * Thread to read and buffer output from an input stream.
         */
        protected static class InputStreamThread extends Thread {
    
            private BufferedReader br;
    
            private final List<String> list = new LinkedList<>();
    
            private final int maxLineBuffer;
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                SingletonLaContainerFactory.setExternalContextComponentDefRegister(new GenericExternalContextComponentDefRegister());
                SingletonLaContainerFactory.init();
    
                final Thread shutdownCallback = new Thread("ShutdownHook") {
                    @Override
                    public void run() {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Destroying LaContainer...");
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java

            }
    
            // Initialize the digest once to validate configuration
            this.digest = createMacInstance();
        }
    
        /**
         * Create a new Mac instance for thread-safe operations
         * @return initialized Mac instance
         * @throws GeneralSecurityException if Mac cannot be created
         */
        private Mac createMacInstance() throws GeneralSecurityException {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/MinimalIterable.java

     *
     * <p>Note that although your APIs should be liberal in what they accept, your methods which
     * <i>return</i> iterables should make every attempt to return ones of the robust variety.
     *
     * <p>This testing utility is not thread-safe.
     *
     * @author Kevin Bourrillion
     */
    @GwtCompatible
    public final class MinimalIterable<E extends @Nullable Object> implements Iterable<E> {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/RuleManagerTest.java

                final int threadId = i;
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            startLatch.await();
                            for (int j = 0; j < rulesPerThread; j++) {
                                TestRule rule = new TestRule("rule_" + threadId + "_" + j, true);
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 23.8K bytes
    - Viewed (0)
Back to top