Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 51 for queueing (0.14 sec)

  1. cmd/global-heal.go

    					madmin.HealOpts{
    						ScanMode: scanMode,
    						Remove:   healDeleteDangling,
    					})
    				if err != nil {
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// queueing happens across namespace, ignore
    						// objects that are not found.
    						return
    					}
    					result = healEntryFailure(0)
    					bgSeq.countFailed(madmin.HealItemObject)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/eventbus/Dispatcher.java

        //    second thread can then dispatch to the subscriber it took before the first thread does.
        //
        // All this makes me really wonder if there's any value in queueing here at all. A dispatcher
        // that simply loops through the subscribers and dispatches the event to each would actually
        // probably provide a stronger order guarantee, though that order would obviously be different
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

     *
     * <p>Key features include:</p>
     * <ul>
     * <li>Incremental crawling support with last-modified timestamp checking</li>
     * <li>Document expiration handling</li>
     * <li>Child URL extraction and queueing</li>
     * <li>Integration with Fess configuration and permission systems</li>
     * <li>Client selection based on URL patterns</li>
     * </ul>
     *
     * @see CrawlerThread
     * @see org.codelibs.fess.crawler.client.CrawlerClient
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.32.md

    - Improve Node QueueHint in the NodeAffinty plugin by ignoring unrelated changes that keep pods unschedulable. ([#127444](https://github.com/kubernetes/kubernetes/pull/127444), [@dom4ha](https://github.com/dom4ha)) [SIG Scheduling and Testing]
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 14:49:49 UTC 2025
    - 412.3K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.29.md

    - In a scheduler with `Permit` plugins, when a Pod is rejected during `WaitOnPermit`, the scheduler records the plugin.
      The scheduler will use the record to honor cluster events and queueing `hints registered` for the plugin, to inform whether to retry the pod. ([#119785](https://github.com/kubernetes/kubernetes/pull/119785), [@sanposhiho](https://github.com/sanposhiho))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Mar 12 00:36:01 UTC 2025
    - 429.6K bytes
    - Viewed (1)
  6. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

          queue.add(submittedTask);
          workerRunningState = QUEUING;
        }
    
        try {
          executor.execute(worker);
        } catch (Throwable t) {
          // Any Exception is either a RuntimeException or sneaky checked exception.
          synchronized (queue) {
            boolean removed =
                (workerRunningState == IDLE || workerRunningState == QUEUING)
                    && queue.removeLastOccurrence(submittedTask);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.24.md

    - Correct event registration for multiple scheduler plugins; this fixes a potential significant delay in re-queueing unschedulable pods. ([#109442](https://github.com/kubernetes/kubernetes/pull/109442), [@ahg-g](https://github.com/ahg-g))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu Aug 24 00:02:43 UTC 2023
    - 473.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/Suggester.java

     * </ul>
     *
     * <p>Public Methods:
     * <ul>
     *   <li>{@link #suggest()}: Creates a new SuggestRequestBuilder for querying suggestions.</li>
     *   <li>{@link #popularWords()}: Creates a new PopularWordsRequestBuilder for querying popular words.</li>
     *   <li>{@link #refresh()}: Refreshes the suggestion indices.</li>
     *   <li>{@link #shutdown()}: Shuts down the thread pool.</li>
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 20.7K bytes
    - Viewed (3)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

        // Enqueueing the red task starts a thread because the head of the queue changed.
        redQueue.execute("red task") {
          log += "red:starting@${taskFaker.nanoTime}"
          taskFaker.sleep(100.µs)
          log += "red:finishing@${taskFaker.nanoTime}"
        }
        assertThat(taskFaker.executeCallCount).isEqualTo(1)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 23K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/MetadataSource.java

     * under the License.
     */
    package org.apache.maven.repository.metadata;
    
    import java.util.List;
    
    import org.apache.maven.artifact.repository.ArtifactRepository;
    
    /**
     * Provides some metadata operations, like querying the remote repository for a list of versions available for an
     * artifact.
     *
     */
    @Deprecated
    public interface MetadataSource {
        String ROLE = MetadataSource.class.getName();
    
        MetadataResolution retrieve(
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.3K bytes
    - Viewed (0)
Back to top