- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,052 for executer (0.06 sec)
-
docs/fr/docs/tutorial/debugging.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Oct 27 17:31:14 UTC 2024 - 2.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically. * * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the * {@link #runOneIteration} that will be executed periodically as specified by its {@linkRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
return this; } /** * Executes the Python script job. * Creates a session ID, sets up the execution environment, and runs the Python script * with the configured filename and arguments. * * @return a string containing the execution result and any error messages */ @Override public String execute() { final StringBuilder resultBuf = new StringBuilder();Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 8.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt
/** * A fake executor for testing that never executes anything! Instead, it just keeps track of what's * been enqueued. */ internal class RecordingExecutor( private val dispatcherTest: DispatcherTest, ) : AbstractExecutorService() { private var shutdown: Boolean = false private val calls = mutableListOf<RealCall.AsyncCall>() override fun execute(command: Runnable) {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Oct 06 18:34:01 UTC 2025 - 2.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java
final int numThreads = 10; final ExecutorService executor = Executors.newFixedThreadPool(numThreads); final CountDownLatch latch = new CountDownLatch(numThreads); final AtomicInteger callbackCount = new AtomicInteger(0); // Add listeners concurrently from multiple threads for (int i = 0; i < numThreads; i++) { executor.submit(() -> { try {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:44:44 UTC 2025 - 17K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* one of the listener's callbacks will execute at once. However, multiple listeners' callbacks * may execute concurrently, and listeners may execute in an order different from the one in which * they were registered. * * <p>RuntimeExceptions thrown by a listener will be caught and logged. Any exception thrown * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException}) will be caught and
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 17:49:12 UTC 2025 - 33.2K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* one of the listener's callbacks will execute at once. However, multiple listeners' callbacks * may execute concurrently, and listeners may execute in an order different from the one in which * they were registered. * * <p>RuntimeExceptions thrown by a listener will be caught and logged. Any exception thrown * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException}) will be caught and
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 17:49:12 UTC 2025 - 32.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
@Nullable Executor delegate; /** * Set before calling delegate.execute(); set to null once run, so that it can be GCed; this * object may live on after, if submitAsync returns an incomplete future. */ @Nullable Runnable task; /** Thread that called execute(). Set in execute, cleared when delegate.execute() returns. */ @LazyInit @Nullable Thread submitting;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
} public void execute(final MavenSession session, final List<MojoExecution> mojoExecutions) throws LifecycleExecutionException { final DependencyContext dependencyContext = newDependencyContext(session, mojoExecutions); final PhaseRecorder phaseRecorder = new PhaseRecorder(session.getCurrentProject());Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Jun 12 14:55:55 UTC 2025 - 21K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
assertEquals(0, numCalls.get()); reject.set(false); executor.execute(task); assertEquals(1, numCalls.get()); } /* * Under Android, MyError propagates up and fails the test? * * TODO(b/218700094): Does this matter to prod users, or is it just a feature of our testing
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 11.4K bytes - Viewed (0)