Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 143 for interrupted (0.25 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/util/concurrent/CombinedFuture.java

          localTask.execute();
        }
      }
    
      @Override
      void releaseResources(ReleaseResourcesReason reason) {
        super.releaseResources(reason);
        /*
         * If the output future is done, then it won't need to interrupt the task later, so it can clear
         * its reference to it.
         *
         * If the output future is *not* done, then the task field will be cleared after the task runs
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.8K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java

            // Wait a bit and update activity
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
    
            channelInfo.updateActivity();
            assertTrue(channelInfo.getLastActivityTime() > initialTime);
            assertTrue(channelInfo.getIdleTime() >= 0);
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  3. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

      @SuppressWarnings("FutureReturnValueIgnored")
      @Footprint(exclude = {Runnable.class, Executor.class, Thread.class, Exception.class})
      public Object measureSize() {
        for (Thread thread : blockedThreads) {
          thread.interrupt();
        }
        blockedThreads.clear();
        Facade<Object> f = impl.newFacade();
        for (int i = 0; i < numThreads; i++) {
          Thread thread =
              new Thread() {
                @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

        validator.validateClass(exceptionClass);
        try {
          return future.get();
        } catch (InterruptedException e) {
          currentThread().interrupt();
          throw newWithCause(exceptionClass, e);
        } catch (ExecutionException e) {
          wrapAndThrowExceptionOrError(e.getCause(), exceptionClass);
          throw new AssertionError();
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/base/Ascii.java

       * Device Control 1. Characters for the control of ancillary devices associated with data
       * processing or telecommunication systems, more especially switching devices "on" or "off." (If a
       * single "stop" control is required to interrupt or turn off ancillary devices, DC4 is the
       * preferred assignment.)
       *
       * @since 8.0
       */
      public static final byte DC1 = 17; // aka XON
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java

                            Thread.yield(); // Allow other threads to run
                        }
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    }
                });
                readerThreads[i].start();
            }
    
            // Writer thread sets alive to false early
            Thread writerThread = new Thread(() -> {
                try {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.8K bytes
    - Click Count (1)
  7. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        break;
                    }
                }
                assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus());
                crawler.awaitTermination();
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Jan 15 01:11:43 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * {@link #runOneIteration} that will be executed periodically as specified by its {@link
     * Scheduler}. When this service is asked to stop via {@link #stopAsync} it will cancel the periodic
     * task (but not interrupt it) and wait for it to stop before running the {@link #shutDown} method.
     *
     * <p>Subclasses are guaranteed that the life cycle methods ({@link #runOneIteration}, {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  10. guava/src/com/google/common/base/Ascii.java

       * Device Control 1. Characters for the control of ancillary devices associated with data
       * processing or telecommunication systems, more especially switching devices "on" or "off." (If a
       * single "stop" control is required to interrupt or turn off ancillary devices, DC4 is the
       * preferred assignment.)
       *
       * @since 8.0
       */
      public static final byte DC1 = 17; // aka XON
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 21.7K bytes
    - Click Count (0)
Back to Top