Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 113 for Executing (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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(): Boolean
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  5. 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)
  6. 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 {@code
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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 in
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  10. 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)
Back to top