- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for queueing (0.1 sec)
-
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) -
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) -
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) -
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) -
cmd/namespace-lock_test.go
}() time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2 // Unlock the 1st lock; ref=1 after this line nsLk.unlock("volume", "path", false) // Taking another lockMapMutex here allows queuing up additional lockers. This should // not be required but makes reproduction much easier. nsLk.lockMapMutex.Lock() // lk3 blocks. lk3ch := make(chan bool) go func() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3K bytes - Viewed (0) -
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) -
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) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stopwords/UploadForm.java
import org.lastaflute.web.validation.Required; /** * Form for uploading stopwords files to the Fess search engine. * Stopwords are common words that should be ignored during search indexing and querying. * This form is used in the admin interface to upload custom stopwords dictionary files. */ public class UploadForm { /**
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 1.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java
*/ public static final byte TRANS2_FIND_NEXT2 = (byte) 0x02; /** * SMB TRANS2 subcommand for querying file system information */ public static final byte TRANS2_QUERY_FS_INFORMATION = (byte) 0x03; /** * SMB TRANS2 subcommand for querying path information */ public static final byte TRANS2_QUERY_PATH_INFORMATION = (byte) 0x05; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 17.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/Smb2ChannelCapabilities.java
/** * Network interface capability flag for RDMA support */ public static final int NETWORK_INTERFACE_CAP_RDMA = 0x00000002; /** * FSCTL code for querying network interface information */ public static final int FSCTL_QUERY_NETWORK_INTERFACE_INFO = 0x001401FC; /** * SMB2 session flag indicating channel binding */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 2.4K bytes - Viewed (0)