Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 146 for interrupted (0.06 seconds)

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

  1. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/EncryptInvoker.java

                context.addInHeader("");
    
                context.terminal.handle(
                        Terminal.Signal.INT, signal -> Thread.currentThread().interrupt());
    
                context.reader =
                        LineReaderBuilder.builder().terminal(context.terminal).build();
    
                if (context.options().goals().isEmpty()
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/UpgradeInvoker.java

                context.addInHeader("");
    
                context.terminal.handle(
                        Terminal.Signal.INT, signal -> Thread.currentThread().interrupt());
    
                context.reader =
                        LineReaderBuilder.builder().terminal(context.terminal).build();
    
                if (context.options().goals().isEmpty()) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/suggest/index/operations/ContentIndexingOperations.java

                try {
                    QueryLog queryLog = queryLogReader.read();
                    while (queryLog != null) {
                        if (Thread.currentThread().isInterrupted()) {
                            break;
                        }
                        queryLogs.add(queryLog);
                        queryLog = queryLogReader.read();
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 21.7K bytes
    - Click Count (0)
  4. src/test/java/jcifs/tests/persistent/PersistentHandleManagerTest.java

                    null);
    
            // Wait for expiration
            try {
                Thread.sleep(150);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
    
            HandleInfo info = manager.getHandleForReconnect("/test/file.txt");
            assertNull(info);
        }
    
        @Test
        public void testCompleteReconnectSuccess() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test getWaitQueueLength(Guard).
      // TODO: Test automatic signaling before leave, waitFor, and reentrant enterWhen.
      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
      // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
      // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.2K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

      override fun request(): Request = originalRequest
    
      /**
       * Immediately closes the socket connection if it's currently held. Use this to interrupt an
       * in-flight request from any thread. It's the caller's responsibility to close the request body
       * and response body streams; otherwise resources may be leaked.
       *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test getWaitQueueLength(Guard).
      // TODO: Test automatic signaling before leave, waitFor, and reentrant enterWhen.
      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
      // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
      // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  8. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * <p>The implementation deviates from the {@code ExecutorService} specification with regards to
       * the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is
       * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing
       * tasks. Second, the returned list will always be empty, as any submitted task is considered to
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/ShellInvoker.java

                                failure.set(e);
                            }
                        });
                        context.terminal.handle(Terminal.Signal.INT, signal -> commandThread.interrupt());
                        commandThread.start();
                        commandThread.join();
                        if (failure.get() != null) {
                            throw failure.get();
                        }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  10. src/main/java/jcifs/audit/SecurityAuditLogger.java

                            processLogEntry(entry);
                            returnAuditEntry(entry);
                        }
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        break;
                    } catch (Exception e) {
                        log.error("Error processing audit log entry", e);
                    }
                }
            });
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 26.6K bytes
    - Click Count (0)
Back to Top