- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 113 for Executing (0.04 sec)
-
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
for (final String sid : sessionIdList) { // remove config ComponentUtil.getCrawlingConfigHelper().remove(sid); } } /** * Inner thread class for executing data store crawling operations. * Each thread handles crawling for a single data configuration, * processing documents and updating the search index. * * <p>The thread manages:</p> * <ul>Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 19K bytes - Viewed (0) -
docs/en/docs/advanced/settings.md
{* ../../docs_src/settings/app03_an_py39/main.py hl[1,11] *} Then for any subsequent call of `get_settings()` in the dependencies for the next requests, instead of executing the internal code of `get_settings()` and creating a new `Settings` object, it will return the same object that was returned on the first call, again and again. #### `lru_cache` Technical Details { #lru-cache-technical-details }Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 20 15:55:38 UTC 2025 - 11.2K bytes - Viewed (0) -
docs/en/docs/fastapi-cli.md
## `fastapi run` { #fastapi-run } Executing `fastapi run` starts FastAPI in production mode by default.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 4.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* * It is possible to cancel the finding process by canceling its call. * * Implementations of this interface are not thread-safe. Each instance is thread-confined to the * thread executing the call. */ interface RoutePlanner { val address: Address /** Follow-ups for failed plans and plans that lost a race. */ val deferredPlans: ArrayDeque<Plan> fun isCanceled(): BooleanRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 4.2K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} type ioret[V any] struct { val V err error } // WithDeadline will execute a function with a deadline and return a value of a given type. // If the deadline/context passes before the function finishes executing, // the zero value and the context error is returned. func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 11.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing * tasks. Second, the returned list will always be empty, as any submitted task is considered to * have started execution. This applies also to tasks given to {@code invokeAll} or {@codeRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 6.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
* need. Both fields are guarded by `this`. */ private var executeCallCount = 0 private var runCallCount = 0 /** Queues with tasks that are currently executing their [TaskQueue.activeTask]. */ private val busyQueues = mutableListOf<TaskQueue>() /** Queues not in [busyQueues] that have non-empty [TaskQueue.futureTasks]. */ private val readyQueues = mutableListOf<TaskQueue>()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
var nanoTime = 0L private set /** Backlog of tasks to run. Only one task runs at a time. Guarded by `this`. */ private val serialTaskQueue = ArrayDeque<SerialTask>() /** The task that's currently executing. Guarded by `this`. */ private var currentTask: SerialTask = TestThreadSerialTask /** The coordinator task if it's waiting, and how it will resume. Guarded by `this`. */Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* <i>happen-before</i></a> its execution begins, perhaps in another thread. * * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners * after executing them. * * @param listener the listener to run when the computation is complete * @param executor the executor to run the listener inRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
} }.apply { timeout(client.callTimeoutMillis.toLong(), MILLISECONDS) } private val executed = AtomicBoolean() // These properties are only accessed by the thread executing the call. /** Initialized in [callStart]. */ private var callStackTrace: Any? = null /** Finds an exchange to send the next request and receive the next response. */Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 19.7K bytes - Viewed (0)