- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 259 for taskCh (0.05 sec)
-
cmd/data-scanner_test.go
LockEnabled: true, } expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) { defer wg.Done() // signal the calling goroutine that the worker is ready tor receive tasks close(readyCh) var expired []ObjectToDelete for t := range taskCh { switch v := t.(type) { case noncurrentVersionsTask: expired = append(expired, v.versions...)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
docs/en/docs/tutorial/background-tasks.md
{* ../../docs_src/background_tasks/tutorial001.py hl[6:9] *} ## Add the background task { #add-the-background-task } Inside of your *path operation function*, pass your task function to the *background tasks* object with the method `.add_task()`: {* ../../docs_src/background_tasks/tutorial001.py hl[14] *} `.add_task()` receives as arguments: * A task function to be run in the background (`write_notification`).
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 4.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt
* decide not to by returning -1L. * * Task Queues * ----------- * * Tasks are bound to the [TaskQueue] they are scheduled in. Each queue is sequential and the tasks * within it never execute concurrently. It is an error to use a task in multiple queues. */ abstract class Task( val name: String, val cancelable: Boolean = true, ) { // Guarded by the TaskRunner. internal var queue: TaskQueue? = null
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
AfterOtherTasks, } /** Returns the task that was started, or null if there were no tasks to start. */ private fun startNextTask(): SerialTask? { taskRunner.assertLockHeld() val index = serialTaskQueue.indexOfFirst { it.isReady() } if (index == -1) return null val nextTask = serialTaskQueue.removeAt(index) currentTask = nextTask
Registered: Fri Sep 05 11:42:10 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/ExecutionSequencer.java
* cancelled). * * <p>This class serializes execution of <i>submitted</i> tasks but not any <i>listeners</i> of * those tasks. * * <p>Submitted 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 #submit} and * {@link #submitAsync} that submitted those tasks had. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 22.1K bytes - Viewed (0) -
docs/es/docs/tutorial/background-tasks.md
{* ../../docs_src/background_tasks/tutorial001.py hl[6:9] *} ## Agregar la tarea en segundo plano Dentro de tu *path operation function*, pasa tu función de tarea al objeto de *background tasks* con el método `.add_task()`: {* ../../docs_src/background_tasks/tutorial001.py hl[14] *} `.add_task()` recibe como argumentos: * Una función de tarea para ejecutar en segundo plano (`write_notification`).
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 4.9K bytes - Viewed (0) -
docs/en/docs/management-tasks.md
# Repository Management Tasks These are the tasks that can be performed to manage the FastAPI repository by [team members](./fastapi-people.md#team){.internal-link target=_blank}. /// tip This section is useful only to a handful of people, team members with permissions to manage the repository. You can probably skip it. 😉 /// ...so, you are a [team member of FastAPI](./fastapi-people.md#team){.internal-link target=_blank}? Wow, you are so cool! 😎
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 14.2K bytes - Viewed (0) -
docs/ru/docs/tutorial/background-tasks.md
{* ../../docs_src/background_tasks/tutorial001.py hl[6:9] *} ## Добавление фоновой задачи Внутри функции вызовите метод `.add_task()` у объекта *background tasks* и передайте ему функцию, которую хотите выполнить в фоне: {* ../../docs_src/background_tasks/tutorial001.py hl[14] *} `.add_task()` принимает следующие аргументы:
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
} /** * Wraps a collection of tasks. * * @throws NullPointerException if any element of {@code tasks} is null */ private <T extends @Nullable Object> ImmutableList<Callable<T>> wrapTasks( Collection<? extends Callable<T>> tasks) { ImmutableList.Builder<Callable<T>> builder = ImmutableList.builder(); for (Callable<T> task : tasks) { builder.add(wrapTask(task)); } return builder.build(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 5.4K bytes - Viewed (0) -
docs/uk/docs/tutorial/background-tasks.md
{* ../../docs_src/background_tasks/tutorial001.py hl[6:9] *} ## Додавання фонової задачі Усередині Вашої *функції обробки шляху*, передайте функцію задачі в об'єкт *background tasks*, використовуючи метод `.add_task()`: {* ../../docs_src/background_tasks/tutorial001.py hl[14] *} `.add_task()` приймає аргументи:
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Fri May 30 13:34:53 UTC 2025 - 7.6K bytes - Viewed (0)