- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for Task (0.14 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* will not be released until that submitted task is also complete. * * <p>If a task is {@linkplain Thread#interrupt interrupted} while a task is running: * * <ol> * <li>execution will not stop until the task queue is empty. * <li>tasks will begin execution with the thread marked as not interrupted - any interruption * applies only to the task that was running at the point of interruption.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleBuildDocumentationPlugin.java
); task.getDocsDirectory().convention(extension.getDocumentationRenderedRoot()); task.getPort().convention(webserverPort); task.dependsOn(extension.getRenderedDocumentation()); }); tasks.register("docs", task -> { task.setDescription("Generates all documentation"); task.setGroup("documentation");
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Apr 17 20:04:00 GMT 2024 - 7.4K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleUserManualPlugin.java
tasks.withType(AsciidoctorTask.class).configureEach(task -> { if (task.getName().equals("asciidoctor")) { // ignore this task task.setEnabled(false); return; } task.setExecutionMode(ExecutionMode.OUT_OF_PROCESS); task.outputOptions(options -> { options.setSeparateOutputDirs(false);
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Mar 01 05:46:51 GMT 2024 - 17.7K bytes - Viewed (0) -
src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java
Thread.sleep(10); int count = expiredCount; task.stop(); TimeoutManager.getInstance().start(); assertNotNull(TimeoutManager.getInstance().thread); Thread.sleep(2000); assertEquals(count, expiredCount); assertEquals(1, TimeoutManager.getInstance().getTimeoutTaskCount()); task.cancel(); Thread.sleep(2000);
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java
} public static void execute(final Runnable task) { ForkJoinPool.commonPool().execute(() -> { final Thread currentThread = Thread.currentThread(); final ClassLoader orignal = currentThread.getContextClassLoader(); currentThread.setContextClassLoader(CommonPoolUtil.class.getClassLoader()); try { task.run(); } catch (final Exception e) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.5K bytes - Viewed (1) -
maven-core/src/main/java/org/apache/maven/project/ProjectModelResolver.java
pool.shutdown(); } return true; } }; pool.submit(task); return task; }); result = future.get(); } catch (Exception e) { throw new UnresolvableModelException(e, parent.getGroupId(), parent.getArtifactId(), parent.getVersion());
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 15.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
final TimeoutTask task = e.getElement(); if (task.isCanceled()) { e.remove(); } else if (!task.isStopped() && task.isExpired()) { expiredTask.add(task); if (!task.isPermanent()) { e.remove(); } } }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
@CheckForNull // null only for TOMBSTONE final Runnable task; @CheckForNull // null only for TOMBSTONE final Executor executor; // writes to next are made visible by subsequent CAS's on the listeners field @CheckForNull Listener next; Listener(Runnable task, Executor executor) { this.task = task; this.executor = executor; } Listener() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.2 */ public static <O extends @Nullable Object> ListenableFuture<O> submit( Callable<O> callable, Executor executor) { TrustedListenableFutureTask<O> task = TrustedListenableFutureTask.create(callable); executor.execute(task); return task; } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/UncheckedExecutionException.java
* ExecutionException}, the exception's {@linkplain #getCause() cause} comes from a failed task, * possibly run in another thread. * * <p>{@code UncheckedExecutionException} is intended as an alternative to {@code * ExecutionException} when the exception thrown by a task is an unchecked exception. However, it * may also wrap a checked exception in some cases. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Mar 07 17:52:19 GMT 2024 - 4.1K bytes - Viewed (0)