Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 77 for exit (0.28 sec)

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

                Thread.interrupted();
                if (interruptingThread.isAlive()) {
                  // This will be hidden by test-output redirection:
                  logger.severe("InterruptenatorTask did not exit; future tests may be affected");
                  /*
                   * This won't do any good under JUnit 3, but I'll leave it around in
                   * case we ever switch to JUnit 4:
                   */
                  fail();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 4.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

       *   ...
       * </pre>
       *
       * <p>The returned handler logs any exception at severity {@code SEVERE} and then shuts down the
       * process with an exit status of 1, indicating abnormal termination.
       */
      public static UncaughtExceptionHandler systemExit() {
        return new Exiter(Runtime.getRuntime());
      }
    
      @VisibleForTesting
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Dec 14 20:35:03 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/UncaughtExceptionHandlersTest.java

      @Override
      protected void setUp() {
        runtimeMock = mock(Runtime.class);
      }
    
      public void testExiter() {
        new Exiter(runtimeMock).uncaughtException(new Thread(), new Exception());
        verify(runtimeMock).exit(1);
      }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 1.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/UncaughtExceptionHandlersTest.java

      @Override
      protected void setUp() {
        runtimeMock = mock(Runtime.class);
      }
    
      public void testExiter() {
        new Exiter(runtimeMock).uncaughtException(new Thread(), new Exception());
        verify(runtimeMock).exit(1);
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 1.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
        // busy loop when interrupt threw.
        runner.join(TimeUnit.SECONDS.toMillis(10));
      }
    
      static final class BrokenChannel extends AbstractInterruptibleChannel {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  6. guava-tests/benchmark/com/google/common/util/concurrent/MoreExecutorsDirectExecutorBenchmark.java

                }
              };
          threads.add(thread);
        }
      }
    
      @AfterExperiment
      void after() {
        for (Thread thread : threads) {
          thread.interrupt(); // try to get them to exit
        }
        threads.clear();
      }
    
      @Footprint
      Object measureSize() {
        return executor;
      }
    
      @Benchmark
      int timeUncontendedExecute(int reps) {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 3.4K bytes
    - Viewed (0)
  7. android/guava-tests/benchmark/com/google/common/util/concurrent/MoreExecutorsDirectExecutorBenchmark.java

                }
              };
          threads.add(thread);
        }
      }
    
      @AfterExperiment
      void after() {
        for (Thread thread : threads) {
          thread.interrupt(); // try to get them to exit
        }
        threads.clear();
      }
    
      @Footprint
      Object measureSize() {
        return executor;
      }
    
      @Benchmark
      int timeUncontendedExecute(int reps) {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 3.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

                Thread.interrupted();
                if (interruptingThread.isAlive()) {
                  // This will be hidden by test-output redirection:
                  logger.severe("InterruptenatorTask did not exit; future tests may be affected");
                  /*
                   * This won't do any good under JUnit 3, but I'll leave it around in
                   * case we ever switch to JUnit 4:
                   */
                  fail();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 4.4K bytes
    - Viewed (1)
  9. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
        // busy loop when interrupt threw.
        runner.join(TimeUnit.SECONDS.toMillis(10));
      }
    
      static final class BrokenChannel extends AbstractInterruptibleChannel {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        service.startAsync().awaitRunning();
        assertTrue(service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
    
        exitRun.countDown(); // the service will exit voluntarily
        executionThread.join();
    
        assertTrue(service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
    
        service.stopAsync().awaitTerminated(); // no-op
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12.7K bytes
    - Viewed (0)
Back to top