- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for worker (0.17 sec)
-
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
/** * This counter prevents an ABA issue where a thread may successfully schedule the worker, the * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the * worker, and then the first thread's call to delegate.execute() returns. Without this counter, * it would observe the QUEUING state and set it to QUEUED, and the worker would never be * scheduled again for future submissions. */ @GuardedBy("queue")
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java
/** * Returns the {@link Executor} that will be used to run this service. Subclasses may override * this method to use a custom {@link Executor}, which may configure its worker thread with a * specific name, thread group or priority. The returned executor's {@link * Executor#execute(Runnable) execute()} method is called when this service is started and * stopped, and should return promptly.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 17 13:59:28 GMT 2023 - 5.3K bytes - Viewed (0) -
android/guava/src/com/google/common/net/HttpHeaders.java
public static final String UNSAFE_URL = "unsafe-url"; } /** * The HTTP <a href="https://www.w3.org/TR/service-workers/#update-algorithm">{@code * Service-Worker}</a> header field name. * * @since 20.0 */ public static final String SERVICE_WORKER = "Service-Worker"; /** The HTTP {@code TE} header field name. */ public static final String TE = "TE";
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:08:08 GMT 2024 - 34.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
@Override public void setUp() { threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain( BlockingQueue<T> q, Collection<? super T> buffer, int maxElements, long timeout,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* Run the service. This method is invoked on the execution thread. Implementations must respond * to stop requests. You could poll for lifecycle changes in a work loop: * * <pre> * public void run() { * while ({@link #isRunning()}) { * // perform a unit of work * } * } * </pre> * * <p>...or you could respond to stop requests by implementing {@link #triggerShutdown()}, which
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * <p>{@linkplain Executor#execute executed} tasks have a happens-before order as defined in the * Java Language Specification. Tasks execute with the same happens-before order that the function * calls to {@link Executor#execute `execute()`} that submitted those tasks had. * * <p>The executor uses {@code delegate} in order to {@link Executor#execute execute} each task in
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) -
guava-tests/test/com/google/common/collect/QueuesTest.java
@Override public void setUp() { threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain( BlockingQueue<T> q, Collection<? super T> buffer, int maxElements, long timeout,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/JapicmpTask.java
import org.gradle.api.tasks.Nested; import org.gradle.api.tasks.Optional; import org.gradle.api.tasks.OutputFile; import org.gradle.api.tasks.TaskAction; import org.gradle.util.GradleVersion; import org.gradle.workers.WorkQueue; import org.gradle.workers.WorkerExecutor; import javax.inject.Inject; import java.io.File; import java.net.URISyntaxException; import java.security.CodeSource; import java.security.ProtectionDomain;
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Apr 26 10:58:32 GMT 2023 - 13.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/net/HostSpecifierTest.java
/** * {@link TestCase} for {@link HostSpecifier}. This is a relatively cursory test, as HostSpecifier * is a thin wrapper around {@link InetAddresses} and {@link InternetDomainName}; the unit tests for * those classes explore numerous corner cases. The intent here is to confirm that everything is * wired up properly. * * @author Craig Berry */ public final class HostSpecifierTest extends TestCase {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Feb 18 15:33:20 GMT 2022 - 3.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ActivityHelper.java
logger = LogManager.getLogger(loggerName); final String logFormat = ComponentUtil.getFessConfig().getAppAuditLogFormat(); if (StringUtil.isBlank(logFormat)) { useEcsFormat = "docker".equals(System.getenv("FESS_APP_TYPE")); } else if ("ecs".equals(logFormat)) { useEcsFormat = true; } } public void login(final OptionalThing<FessUserBean> user) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.7K bytes - Viewed (0)