- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 725 for reread (0.11 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* approach would be for each caller CAS it from null to a Set populated with its exception. But * there's another race: If the first thread fails with an exception and a second thread * immediately fails with the same exception: * * Thread1: calls setException(), which returns true, context switch before it can CAS * seenExceptions to its exception *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
api/maven-api-meta/src/main/java/org/apache/maven/api/annotations/ThreadSafe.java
import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * The {@code ThreadSafe} annotation can be used to indicate a given type * is thread safe. {@link Immutable} objects are automatically thread safe. * * @see Immutable * @see NotThreadSafe * @since 4.0.0 */ @Experimental @Documented @Retention(RetentionPolicy.CLASS) @Target(ElementType.TYPE)
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Mar 23 05:29:39 UTC 2023 - 1.4K bytes - Viewed (0) -
src/test/java/org/codelibs/core/lang/ClassLoaderUtilTest.java
final ClassLoader context = Thread.currentThread().getContextClassLoader(); try { final ClassLoader cl = new URLClassLoader(new URL[0], getClass().getClassLoader()); Thread.currentThread().setContextClassLoader(cl); assertThat(ClassLoaderUtil.getClassLoader(TestCase.class), is(sameInstance(cl))); } finally { Thread.currentThread().setContextClassLoader(context);
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* * It is possible to cancel the finding process by canceling its call. * * Implementations of this interface are not thread-safe. Each instance is thread-confined to the * thread executing the call. */ interface RoutePlanner { val address: Address /** Follow-ups for failed plans and plans that lost a race. */ val deferredPlans: ArrayDeque<Plan>
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 4.2K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsuleFactory.java
} }); ClassLoader oldCL = Thread.currentThread().getContextClassLoader(); try { container.setLookupRealm(null); container.setLoggerManager(createLoggerManager()); container.getLoggerManager().setThresholds(toPlexusLoggingLevel(context.loggerLevel)); Thread.currentThread().setContextClassLoader(container.getContainerRealm());
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 13.6K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
// // DeviceThread itself is thread-safe, in that StartExecute will block if there // is a pending execution. Since StartExecute is equivalent to grabbing a lock, // multiple DeviceThreads should always be accessed in the same order to avoid // deadlocks. class DeviceThread { public: // Starts a background thread waiting for `StartExecute`.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Oct 21 04:14:14 UTC 2024 - 25.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
@ElementTypesAreNonnullByDefault public final class JdkFutureAdapters { /** * Assigns a thread to the given {@link Future} to provide {@link ListenableFuture} functionality. * * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
tests/test_tutorial/test_extra_data_types/test_tutorial001_an.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Apr 19 00:11:40 UTC 2024 - 6.8K bytes - Viewed (0) -
docs/em/docs/deployment/manually.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
/** The next byte to read. This is always less than or equal to [upstreamPos]. */ private var sourcePos = 0L /** * Selects where to find the bytes for a read and read them. This is one of three sources. * * ## Upstream * * In this case the current thread is assigned as the upstream reader. We read bytes from
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.8K bytes - Viewed (0)