Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 827 for _clear (0.04 sec)

  1. guava-tests/test/com/google/common/util/concurrent/TestThread.java

      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
      // may put a thread into an uninterruptible operation intentionally, so there is no other way to
      // clean up these threads.
      @SuppressWarnings("deprecation")
      @Override
      public void tearDown() throws Exception {
        stop();
        join();
    
        if (uncaughtThrowable != null) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java

            return handles.size();
        }
    
        private void periodicMaintenance() {
            if (shutdown) {
                return;
            }
    
            lock.writeLock().lock();
            try {
                // Clean up expired handles
                handles.entrySet().removeIf(entry -> {
                    HandleInfo info = entry.getValue();
                    if (info.isExpired() && !info.isReconnecting()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:49:49 UTC 2025
    - 13K bytes
    - Viewed (0)
  3. docs/en/docs/advanced/events.md

    This can be very useful for setting up **resources** that you need to use for the whole app, and that are **shared** among requests, and/or that you need to **clean up** afterwards. For example, a database connection pool, or loading a shared machine learning model.
    
    ## Use Case { #use-case }
    
    Let's start with an example **use case** and then see how to solve it with this.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	ahs.Lock()
    	defer ahs.Unlock()
    
    	for _, ep := range healLocalDisks {
    		ahs.healLocalDisks[ep] = false
    	}
    }
    
    func (ahs *allHealState) periodicHealSeqsClean(ctx context.Context) {
    	// Launch clean-up routine to remove this heal sequence (after
    	// it ends) from the global state after timeout has elapsed.
    	periodicTimer := time.NewTimer(time.Minute * 5)
    	defer periodicTimer.Stop()
    
    	for {
    		select {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

            });
            saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL));
            return redirect(getClass());
        }
    
        /**
         * Clears all crawler indices including queue, data, and filter indices.
         *
         * @param form the action form (validated but not used for configuration)
         * @return HTML response redirecting to the maintenance page
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java

                assertTrue("Content should contain 'Thread:'", content.contains("Thread:"));
                assertTrue("Content should contain stack trace elements", content.contains("\tat "));
    
            } finally {
                // Clean up
                Files.deleteIfExists(tempFile);
            }
        }
    
        public void test_writeThreadDump_withInvalidPath() {
            // Test with invalid file path (directory that doesn't exist)
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/filter/WebApiFilterTest.java

        @Override
        public void setUp() throws Exception {
            super.setUp();
            webApiFilter = new WebApiFilter();
        }
    
        @Override
        public void tearDown() throws Exception {
            // Clear WebApiManagerFactory
            super.tearDown();
        }
    
        // Test constructor
        public void test_constructor() {
            assertNotNull(new WebApiFilter());
        }
    
        // Test init method
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.2K bytes
    - Viewed (0)
  8. docs/es/docs/tutorial/index.md

    ---
    
    ## Instalar FastAPI
    
    El primer paso es instalar FastAPI.
    
    Asegúrate de crear un [entorno virtual](../virtual-environments.md){.internal-link target=_blank}, actívalo, y luego **instala FastAPI**:
    
    <div class="termy">
    
    ```console
    $ pip install "fastapi[standard]"
    
    ---> 100%
    ```
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 17:46:44 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          sleepMicros("R", micros);
        }
    
        String readEventsAndClear() {
          try {
            return events.toString();
          } finally {
            events.clear();
          }
        }
    
        @Override
        public String toString() {
          return events.toString();
        }
      }
    
      @AndroidIncompatible // Mockito loses its ability to mock doGetRate as of Android 21
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  10. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

          monitor.leave();
        }
      }
    
      /**
       * Atomically removes all of the elements from this queue. The queue will be empty after this call
       * returns.
       */
      @Override
      public void clear() {
        E[] items = this.items;
        Monitor monitor = this.monitor;
        monitor.enter();
        try {
          int i = takeIndex;
          int k = count;
          while (k-- > 0) {
            items[i] = null;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
Back to top