- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for isWorkerThread (0.17 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultSynchronizer.java
} finally { releaseOwnership(previous); } } private Thread takeOwnership() { final Thread currentThread = Thread.currentThread(); if (!workerLeaseService.isWorkerThread()) { throw new IllegalStateException("The current thread is not registered as a worker thread."); } synchronized (this) { if (owner == null) { owner = currentThread;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.7K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/work/TestWorkerLeaseService.groovy
} @Override <T> T withLock(Factory<T> action) { return action.create() } } } @Override boolean isWorkerThread() { return true } @Override void runAsIsolatedTask(Runnable runnable) { runnable.run() } @Override <T> T runAsIsolatedTask(Factory<T> action) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerThreadRegistry.java
*/ WorkerLeaseRegistry.WorkerLeaseCompletion maybeStartWorker(); /** * Returns {@code true} when this thread is enlisted in resource locking. */ boolean isWorkerThread();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 3.6K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/DefaultBuildController.java
build.ensureProjectsLoaded(); return build.getProjects().getProject(Path.path(projectIdentity.getProjectPath())); } private void assertCanQuery() { if (!workerThreadRegistry.isWorkerThread()) { throw new IllegalStateException("A build controller cannot be used from a thread that is not managed by Gradle."); } } @Override public void dispatch(Object value) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 08:56:14 UTC 2024 - 8.4K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/DefaultWorkerExecutor.java
asyncWorkTracker.registerWork(currentBuildOperation, execution); return execution; } private void checkIsManagedThread() { if (!workerThreadRegistry.isWorkerThread()) { throw new IllegalStateException("An attempt was made to submit work from a thread not managed by Gradle. Work may only be submitted from a Gradle-managed thread."); } } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 15.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
} @Override public DefaultWorkerLease newWorkerLease() { return workerLeaseLockRegistry.newResourceLock(); } @Override public boolean isWorkerThread() { return workerLeaseLockRegistry.holdsLock(); } @Override public <T> T runAsWorkerThread(Factory<T> action) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/configurations/DefaultConfiguration.java
return currentState.get(); } ResolverResults newState; if (!domainObjectContext.getModel().hasMutableState()) { if (!workerThreadRegistry.isWorkerThread()) { // Error if we are executing in a user-managed thread. throw new IllegalStateException("The configuration " + identityPath.toString() + " was resolved from a thread not managed by Gradle.");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:36:01 UTC 2024 - 85.4K bytes - Viewed (0)