- Sort Score
- Num 10 results
- Language All
Results 421 - 430 of 470 for executors (0.89 seconds)
-
src/test/java/org/codelibs/fess/query/MatchAllQueryCommandTest.java
assertNotNull(result); // Note: Actual log output verification would require a log appender mock // but we can at least ensure the method executes without errors logger.info("Execute method called with query: {} and boost: {}", query, boost); } @Test public void test_execute_withHighBoost() { // Test execute with high boost valueCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 17K bytes - Click Count (0) -
internal/event/target/mysql.go
// FIXME: log returned error. ignore time being. _ = target.insertStmt.Close() } if target.db != nil { return target.db.Close() } return nil } // Executes the table creation statements. func (target *MySQLTarget) executeStmts() error { _, err := target.db.Exec(fmt.Sprintf(mysqlTableExists, target.args.Table)) if err != nil { createStmt := mysqlCreateNamespaceTable
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 11.6K bytes - Click Count (0) -
internal/ioutil/ioutil.go
return p.p.Get() } // Put a block. func (p *AlignedBytePool) Put(pb *[]byte) { if pb != nil && len(*pb) == p.size { p.p.Put(pb) } } // WriteOnCloser implements io.WriteCloser and always // executes at least one write operation if it is closed. // // This can be useful within the context of HTTP. At least // one write operation must happen to send the HTTP headers // to the peer. type WriteOnCloser struct {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 11.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/PythonJobTest.java
String result = pythonJob.execute(); assertTrue(result.contains("Session Id:")); assertTrue(result.contains("Python Process terminated.")); } // Test execute with job executor @Test public void test_execute_withJobExecutor() { pythonJob.filename("test.py"); TestJobExecutor jobExecutor = new TestJobExecutor(); pythonJob.jobExecutor = jobExecutor;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 22.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
*/ requireNonNull(futures); // Corner case: List is empty. if (futures.isEmpty()) { handleAllCompleted(); return; } // NOTE: If we ever want to use a custom executor here, have a look at CombinedFuture as we'll // need to handle RejectedExecutionException if (allMustSucceed) { // We need fail fast, so we have to keep track of which future failed so we can propagateCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 16K bytes - Click Count (0) -
docs/fr/docs/python-types.md
/// ## Motivation { #motivation } Commençons par un exemple simple : {* ../../docs_src/python_types/tutorial001_py310.py *} Exécuter ce programme affiche : ``` John Doe ``` La fonction fait ce qui suit : * Prend un `first_name` et un `last_name`. * Convertit la première lettre de chacun en majuscule avec `title()`.Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 12.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
/** Parameter key for controlling retention of expired documents */ private static final String KEEP_EXPIRES_DOCS = "keep_expires_docs"; /** * Interval in milliseconds between crawler thread executions. * Used to control the rate at which new crawler threads are started * and the frequency of status checks. */ protected long crawlingExecutionInterval = Constants.DEFAULT_CRAWLING_EXECUTION_INTERVAL;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 19K bytes - Click Count (0) -
docs/pt/docs/advanced/behind-a-proxy.md
## Testando localmente com Traefik { #testing-locally-with-traefik } Você pode facilmente executar o experimento localmente com um prefixo de path removido usando [Traefik](https://docs.traefik.io/).Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:20:43 GMT 2026 - 16.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
return name.endsWith(".log") || name.endsWith(".log.gz"); } /** * Rebuilds selected configuration indices with the latest mappings. * Executes asynchronously in a background thread. * * @param form the action form containing the target index checkboxes and loadBulkData flag * @return HTML response redirecting to the maintenance page */
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 23K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticatorTest.java
// Small wait to allow scheduled task to start Thread.sleep(100); } catch (Exception e) { // May throw due to null user when task executes, which is expected } assertTrue("scheduleParentGroupLookup should complete without immediate error", true); } /** * Test that empty groupIds list does not schedule any task.Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 19.3K bytes - Click Count (0)