Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 259 for taskCh (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top