- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 614 for threads (0.1 sec)
-
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* * Our solution is for threads to CAS seenExceptions from null to a Set populated with _the * initial exception_, no matter which thread does the work. This ensures that seenExceptions * always contains not just the current thread's exception but also the initial thread's. */ Set<Throwable> seenExceptionsLocal = seenExceptions;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionError.java
* possibly run in another thread. That cause should itself be an {@code Error}; if not, use {@code * ExecutionException} or {@link UncheckedExecutionException}. This allows the client code to * continue to distinguish between exceptions and errors, even when they come from other threads. * * @author Chris Povirk * @since 10.0 */ @GwtCompatible
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Mar 07 17:52:19 UTC 2024 - 3.8K bytes - Viewed (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java
test(listener, session, resource, bytes); }); } // start all threads at once try { startLatch.await(); } catch (InterruptedException e) { e.printStackTrace(); } // wait for all thread to end try { endLatch.await(); } catch (InterruptedException e) { e.printStackTrace();
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5K bytes - Viewed (0) -
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. */ @CheckForNull private transient volatile Entry<K, V> cacheEntry;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
src/test/java/jcifs/tests/TimeoutTest.java
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 12.4K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* Support asynchronous disconnects by breaking the socket only. This should prevent flakiness from multiple threads concurrently accessing a stream. ## Version 1.5.3 _2014-03-29_ * Fix bug where the Content-Length header was not always dropped when following a redirect from a POST to a GET. * Implement basic support for `Thread.interrupt()`. OkHttp now checks for an interruption before doing a blocking call. If it is interrupted,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 6.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/TreeBasedTable.java
* {@link Map} specified in the {@link Table} interface. * * <p>Note that this implementation is not synchronized. If multiple threads access this table * concurrently and one of the threads modifies the table, it must be synchronized externally. * * <p>See the Guava User Guide article on <a href=
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 11.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/RemovalListener.java
* due to eviction resulting from timed expiration, exceeding a maximum size, or garbage collection. * * <p>An instance may be called concurrently by multiple threads to process different entries. * Implementations of this interface should avoid performing blocking calls or synchronizing on * shared resources. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
@Override public Integer call() { return Thread.currentThread().getStackTrace().length; } }, directExecutor()); settableFuture.set(null); assertThat(getDone(stackDepthCheck)) .isLessThan(Thread.currentThread().getStackTrace().length + 100); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 7.3K bytes - Viewed (0)