Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,054 for Spread (0.05 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

              @Override
              public void run() {
                list.execute();
              }
            };
        Thread thread1 = new Thread(execute);
        Thread thread2 = new Thread(execute);
        thread1.start();
        thread2.start();
        assertEquals(0, runCalled.get());
        okayToRun.countDown();
        thread1.join();
        thread2.join();
        assertEquals(1, runCalled.get());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

          }
          return;
        }
    
        /*
         * This is an unsynchronized read! After the read, the function returns immediately or acquires
         * the lock to check again. Since an IDLE state was observed inside the preceding synchronized
         * block, and reference field assignment is atomic, this may save reacquiring the lock when
         * another thread or the worker task has cleared the count and set the state.
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

          }
          return;
        }
    
        /*
         * This is an unsynchronized read! After the read, the function returns immediately or acquires
         * the lock to check again. Since an IDLE state was observed inside the preceding synchronized
         * block, and reference field assignment is atomic, this may save reacquiring the lock when
         * another thread or the worker task has cleared the count and set the state.
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/graph/MapIteratorCache.java

       * As such, this field must be cleared before every map mutation.
       *
       * Note about volatile: volatile doesn't make it safe to read from a mutable graph in one thread
       * while writing to it in another. All it does is help with _reading_ from multiple threads
       * concurrently. For more information, see AbstractNetworkTest.concurrentIteration.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 06 00:47:57 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                });
        assertFalse(task.isDone());
        Thread thread =
            new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      task.run();
                    } finally {
                      exitLatch.countDown();
                    }
                  }
                });
        thread.start();
        enterLatch.await();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/hash/BloomFilterTest.java

        List<Thread> threads = new ArrayList<>(numThreads);
        final List<Throwable> exceptions = new ArrayList<>(numThreads);
        for (int i = 0; i < numThreads; i++) {
          Thread thread = new Thread(task);
          thread.setUncaughtExceptionHandler(
              new UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread t, Throwable e) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

         *       observing a null thread does not mean the object is safe to reuse.
         *   <li>If this field's value is some other thread object, we know that it's not our thread.
         *   <li>If this field's value == null because it originally belonged to another thread and that
         *       thread cleared it, we still know that it's not associated with our thread
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

      /**
       * Returns an exception handler that exits the system. This is particularly useful for the main
       * thread, which may start up other, non-daemon threads, but fail to fully initialize the
       * application successfully.
       *
       * <p>Example usage:
       *
       * <pre>
       * public static void main(String[] args) {
       *   Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());
       *   ...
       * </pre>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  9. doc/next/6-stdlib/99-minor/os/user/68647.md

    On Windows, [Current] now returns the process owner user when
    the current thread is impersonating another user. Previously,
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 21 19:59:22 UTC 2024
    - 146 bytes
    - Viewed (0)
  10. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

        try {
          for (i in 1..2) {
            // Space out traffic to make it easier to demarcate.
            sendTestRequest(fbRequest)
            Thread.sleep(1000)
            sendTestRequest(twitterRequest)
            Thread.sleep(1000)
            sendTestRequest(googleRequest)
            Thread.sleep(2000)
          }
        } finally {
          client.connectionPool.evictAll()
          client.dispatcher.executorService.shutdownNow()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
Back to top