Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 41 for cleaners (0.19 seconds)

  1. docs/en/docs/async.md

    But in this case, if you could bring the 8 ex-cashier/cooks/now-cleaners, and each one of them (plus you) could take a zone of the house to clean it, you could do all the work in **parallel**, with the extra help, and finish much sooner.
    
    In this scenario, each one of the cleaners (including you) would be a processor, doing their part of the job.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 23.4K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/base/FinalizableReferenceQueue.java

     *     serverSocket.close();
     *   }
     * }
     * }
     *
     * <p id="cleaner">Here is how you might achieve the same thing using {@link java.lang.ref.Cleaner
     * Cleaner}, if you are using a Java version where that is available:
     *
     * {@snippet :
     * public class MyServer implements Closeable {
     *   private static final Cleaner cleaner = Cleaner.create();
     *   // You might also share this between several objects.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 19:26:59 GMT 2026
    - 15.8K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

        assertThat(serverSocket.isClosed()).isTrue();
      }
    
      @SuppressWarnings("Java8ApiChecker")
      static class MyServerExampleWithCleaner implements AutoCloseable {
        private static final Cleaner cleaner = Cleaner.create();
    
        private static Runnable closeServerSocketRunnable(
            ServerSocket serverSocket, AtomicBoolean cleanerRan) {
          return () -> {
            try {
              serverSocket.close();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Feb 27 21:20:19 GMT 2026
    - 8.6K bytes
    - Click Count (0)
  4. guava/src/com/google/common/base/FinalizableReferenceQueue.java

     *     serverSocket.close();
     *   }
     * }
     * }
     *
     * <p id="cleaner">Here is how you might achieve the same thing using {@link java.lang.ref.Cleaner
     * Cleaner}, if you are using a Java version where that is available:
     *
     * {@snippet :
     * public class MyServer implements Closeable {
     *   private static final Cleaner cleaner = Cleaner.create();
     *   // You might also share this between several objects.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 19:26:59 GMT 2026
    - 15.8K bytes
    - Click Count (0)
  5. internal/lru/lru.go

    		c.removeElement(ent)
    	}
    	c.nextCleanupBucket = (c.nextCleanupBucket + 1) % numBuckets
    	c.mu.Unlock()
    }
    
    // addToBucket adds entry to expire bucket so that it will be cleaned up when the time comes. Has to be called with lock!
    func (c *LRU[K, V]) addToBucket(e *Entry[K, V]) {
    	bucketID := (numBuckets + c.nextCleanupBucket - 1) % numBuckets
    	e.ExpireBucket = bucketID
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/script/groovy/GroovyEngine.java

     * static state, so this is acceptable.</p>
     *
     * <p>Resource Management: Each cached entry's GroovyClassLoader is closed on
     * eviction via RemovalListener. All remaining entries are cleaned up via close() (@PreDestroy).</p>
     */
    public class GroovyEngine extends AbstractScriptEngine {
        private static final Logger logger = LogManager.getLogger(GroovyEngine.class);
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 11.9K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/chat/ChatSessionManager.java

                        session.getMessages().size());
            }
            return true;
        }
    
        /**
         * Clears the messages in a session with userId ownership check.
         *
         * @param sessionId the session ID
         * @param userId the user ID for ownership verification (can be null)
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 07 13:27:59 GMT 2026
    - 13.7K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java

                            .execute()) {
                        if (deleteResponse.getHttpStatusCode() == 200) {
                            if (logger.isInfoEnabled()) {
                                logger.info("Cleaned up stale operation: operation={}, previousOwner={}", operationName, ownerInstanceId);
                            }
                            // Retry creation
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 33.3K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/opensearch/client/SearchEngineClientRebuildTest.java

            final boolean result = testClient.reindexConfigIndices(false, allTargetPrefixes());
    
            assertFalse(result);
            // Backup should be cleaned up
            assertTrue(testClient.deletedIndices.size() > 0, "Backup indices should be cleaned up");
        }
    
        @Test
        public void test_reindexConfigIndices_reindexFromBackupFailureCleansUp() {
            testClient.existsIndexResult = true;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 28.6K bytes
    - Click Count (0)
  10. build-logic/build-update-utils/src/main/kotlin/gradlebuild.update-versions.gradle.kts

    tasks.register<PreparePatchRelease>("preparePatchRelease") {
        group = "Versioning"
        description = "Prepares the repository for a patch release: bumps version.txt, updates released-versions.json, and clears accepted API changes."
        versionFile = layout.projectDirectory.file("version.txt")
        releasedVersionsFile = releasedVersionsFile()
        dependsOn(":architecture-test:cleanAcceptedApiChanges")
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 23 14:47:12 GMT 2026
    - 2.8K bytes
    - Click Count (0)
Back to Top