- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 136 for clocks (0.19 sec)
-
.github/workflows/notify-on-rc-for-manual-test.yml
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 02 09:13:16 UTC 2024 - 1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/ExclusiveCacheAccessCoordinator.java
*/ <T> T useCache(Supplier<? extends T> action); /** * Performs some work against the cache. Acquires exclusive locks on the appropriate resources, so that the given action is the only action to execute across all processes (including this one). Releases the locks and all resources at the end of the action.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/WorkerControl.java
public interface WorkerControl { /** * Starts the worker process, blocking until successfully started. */ WorkerProcess start(); /** * Requests that the worker complete all work and stop. Blocks until the worker process has stopped. */ ExecResult stop(); /** * Requests that the worker stop immediately, without waiting for it to complete its work. */ void stopNow();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:54:37 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/MessagingClient.java
*/ @ServiceScope(Scope.Global.class) public interface MessagingClient { /** * Creates a connection to the given address. Blocks until the connection has been established. * * @param address The address to connect to. */ ObjectConnection getConnection(Address address);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/internal/daemon/clientinput/StdInStreamTest.groovy
import org.gradle.internal.logging.events.ReadStdInEvent import org.gradle.test.fixtures.concurrent.ConcurrentSpec class StdInStreamTest extends ConcurrentSpec { def "read byte requests input from client and blocks until it is available"() { def dispatch = Mock(OutputEventListener) def stream = new StdInStream(dispatch) def text = "some text" def bytes = text.bytes when: async {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonConnection.java
/** * Receives a message from the client. Does not include any stdin messages. Blocks until a message is received or the connection is closed or the timeout is reached. * * @return null On end of connection or timeout. */ Object receive(long timeoutValue, TimeUnit timeoutUnits); /** * Blocks until all handlers have been notified and any queued messages have been dispatched to the client. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/time/build.gradle.kts
* limitations under the License. */ plugins { id("gradlebuild.distribution.implementation-java") id("gradlebuild.publish-public-libraries") } description = "Monotonic clock implementation" gradlebuildJava.usedInWorkers() dependencies { api(projects.stdlibJavaExtensions)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 869 bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/OutgoingConnector.java
import org.gradle.internal.service.scopes.ServiceScope; @ServiceScope(Scope.Global.class) public interface OutgoingConnector { /** * Creates a connection to the given address. Blocks until the connection with the peer has been established. * * @throws ConnectException when there is nothing listening on the remote address. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.2K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/api/internal/tasks/userinput/DefaultUserInputReaderTest.groovy
def userInputReader = new DefaultUserInputReader() def "blocks until user response received"() { expect: async { start { def result = userInputReader.readInput() instant.read assert result == response } thread.block() instant.put userInputReader.putInput(response) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/jvm/language-jvm/build.gradle.kts
id("gradlebuild.instrumented-project") } description = """Contains some base and shared classes for JVM language support, like AbstractCompile class and BaseForkOptions classes, JVM-specific dependencies blocks and JVM test suite interfaces.""" errorprone { disabledChecks.addAll( "OverridesJavaxInjectableMethod", // 1 occurrences "UnusedMethod", // 1 occurrences "UnusedVariable", // 1 occurrences
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 1.9K bytes - Viewed (0)