- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 44 for Synchronizer (0.36 sec)
-
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/health/memory/DefaultMemoryManager.java
} } } @Override public void addMemoryHolder(MemoryHolder holder) { synchronized (holdersLock) { holders.add(holder); } } @Override public void removeMemoryHolder(MemoryHolder holder) { synchronized (holdersLock) { holders.remove(holder); } } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:38 UTC 2024 - 9K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/main/java/org/gradle/testfixtures/internal/TestInMemoryCacheFactory.java
synchronized (this) { return action.get(); } } @Override public void useCache(Runnable action) { assertNotClosed(); // The contract of useCache() means we have to provide some basic synchronization. synchronized (this) { action.run(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 21:54:27 UTC 2024 - 6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/SystemProperties.java
* * @param propertyName The name of the property to set * @param value The value to temporarily set the property to * @param factory Instance created by the Factory implementation */ public synchronized <T> T withSystemProperty(String propertyName, String value, Factory<T> factory) { String originalValue = overrideProperty(propertyName, value); try { return factory.create();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
synchronized (state) { if (state.seenExceptions == expect) { state.seenExceptions = update; } } } @Override int decrementAndGetRemainingCount(AggregateFutureState<?> state) { synchronized (state) { return --state.remaining; } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java
private final Map<TransferResourceIdentifier, TransferResourceAndSize> transfers = new LinkedHashMap<>(); private final FileSizeFormat format = new FileSizeFormat(); // use in a synchronized fashion private final StringBuilder buffer = new StringBuilder(128); // use in a synchronized fashion private final boolean printResourceNames; private int lastLength; public ConsoleMavenTransferListener(
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 21:48:41 UTC 2024 - 5.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
synchronized (state) { if (state.seenExceptions == expect) { state.seenExceptions = update; } } } @Override int decrementAndGetRemainingCount(AggregateFutureState<?> state) { synchronized (state) { return --state.remaining; } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/exceptions/DefaultMultiCauseException.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 5.9K bytes - Viewed (0) -
platforms/core-runtime/build-process-services/src/main/java/org/gradle/internal/installation/CurrentGradleInstallation.java
return gradleInstallation; } @Nullable // if no installation can be located public static GradleInstallation get() { return locate().getInstallation(); } public synchronized static CurrentGradleInstallation locate() { if (instance == null) { instance = CurrentGradleInstallationLocator.locate(); } return instance; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 06:16:07 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/exceptions/DefaultMultiCauseExceptionNoStackTrace.java
} public DefaultMultiCauseExceptionNoStackTrace(Factory<String> messageFactory, Iterable<? extends Throwable> causes) { super(messageFactory, causes); } @Override public synchronized Throwable fillInStackTrace() { return this; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 1.5K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_send_device_context.cc
if (!status.ok()) { done(status); return; } if (auto st = stream_->BlockHostUntilDone(); !st.ok()) { done_event_.SetError(absl::InternalError(absl::StrFormat( "failed to synchronize send operation with a stream: %s", st.ToString()))); return; } done_event_.SetStateConcrete(); done(absl::OkStatus()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 1.6K bytes - Viewed (0)