- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 748 for Synchronizer (1.77 sec)
-
src/main/java/jcifs/smb1/util/transport/Transport.java
protected abstract void doSend( Request request ) throws IOException; protected abstract void doRecv( Response response ) throws IOException; protected abstract void doSkip() throws IOException; public synchronized void sendrecv( Request request, Response response, long timeout ) throws IOException { makeKey( request ); response.isReceived = false; try {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/internal/cache/CacheConfigurationsInternal.java
void finalizeConfiguration(Gradle gradle); /** * Synchronizes the property values of the provided cache configurations with those of this cache configuration * by setting the provided configuration's properties to be backed by the properties of this configuration. */ void synchronize(CacheConfigurationsInternal cacheConfigurationsInternal);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 26 20:02:29 UTC 2024 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Subscriber.java
bus.handleSubscriberException(e.getCause(), context(event)); } }); } /** * Invokes the subscriber method. This method can be overridden to make the invocation * synchronized. */ @VisibleForTesting void invokeSubscriberMethod(Object event) throws InvocationTargetException { try { method.invoke(target, checkNotNull(event)); } catch (IllegalArgumentException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Subscriber.java
bus.handleSubscriberException(e.getCause(), context(event)); } }); } /** * Invokes the subscriber method. This method can be overridden to make the invocation * synchronized. */ @VisibleForTesting void invokeSubscriberMethod(Object event) throws InvocationTargetException { try { method.invoke(target, checkNotNull(event)); } catch (IllegalArgumentException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ProducerGuard.java
import java.util.HashSet; import java.util.Set; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.function.Supplier; /** * Synchronizes access to some resource, by making sure that 2 threads do not try to produce it at the same time. * The resource to be accessed is represented by a key, and the factory is whatever needs to be done to produce it.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:31 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * Connection decorator that synchronizes dispatching and always flushes after each message. * * The plan is to replace this with a Connection implementation that queues outgoing messages and dispatches them from a worker thread. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Nov 01 18:12:21 UTC 2020 - 24.1K bytes - Viewed (0) -
src/sync/rwmutex.go
// // In the terminology of [the Go memory model], // the n'th call to [RWMutex.Unlock] “synchronizes before” the m'th call to Lock // for any n < m, just as for [Mutex]. // For any call to RLock, there exists an n such that // the n'th call to Unlock “synchronizes before” that call to RLock, // and the corresponding call to [RWMutex.RUnlock] “synchronizes before” // the n+1'th call to Lock. // // [the Go memory model]: https://go.dev/ref/mem
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureInnocuousThreadTest.java
if (name.startsWith(concurrentPackage) // Use other classloader for ListenableFuture, so that the objects can interact && !ListenableFuture.class.getName().equals(name)) { synchronized (loadedClasses) { Class<?> toReturn = loadedClasses.get(name); if (toReturn == null) { toReturn = super.findClass(name); loadedClasses.put(name, toReturn);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 16 19:54:45 UTC 2020 - 5.1K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/file/FileSystemOperations.java
*/ WorkResult copy(Action<? super CopySpec> action); /** * Synchronizes the contents of a destination directory with some source directories and files. * The given action is used to configure a {@link CopySpec}, which is then used to synchronize the files. * * @param action action Action to configure the CopySpec.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 15 08:02:27 UTC 2024 - 5.2K bytes - Viewed (0)