Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for queueing (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/main/java/jcifs/smb1/dcerpc/msrpc/MsrpcQueryInformationPolicy.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    
    package jcifs.smb1.dcerpc.msrpc;
    
    import jcifs.smb1.dcerpc.ndr.NdrObject;
    
    /**
     * MSRPC implementation for querying LSA policy information.
     * This class provides functionality to retrieve information about
     * LSA policy settings using the LSA RPC interface.
     */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/artifact/metadata/ArtifactMetadataSource.java

    import org.apache.maven.artifact.versioning.ArtifactVersion;
    import org.apache.maven.repository.legacy.metadata.MetadataResolutionRequest;
    
    /**
     * Provides some metadata operations, like querying the remote repository for a list of versions available for an
     * artifact - deprecated
     */
    @Deprecated
    public interface ArtifactMetadataSource extends org.apache.maven.repository.legacy.metadata.ArtifactMetadataSource {
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb1/trans2/Trans2QueryPathInformation.java

    import jcifs.internal.fscc.FileInformation;
    import jcifs.internal.smb1.trans.SmbComTransaction;
    import jcifs.internal.util.SMBUtil;
    import jcifs.util.Hexdump;
    
    /**
     * Trans2 QueryPathInformation request message for querying file metadata.
     * This class implements the TRANS2_QUERY_PATH_INFORMATION transaction to retrieve
     * various file information levels such as basic info, standard info, and attributes.
     */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4K bytes
    - Viewed (0)
Back to top