Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for _exit (0.12 sec)

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

      //         for (int i = 0; i < iters; ++i) {
      //             junit.textui.TestRunner.run(s);
      //             System.gc();
      //             System.runFinalization();
      //         }
      //         System.exit(0);
      //     }
    
      //     public static TestSuite newTestSuite(Object... suiteOrClasses) {
      //         TestSuite suite = new TestSuite();
      //         for (Object suiteOrClass : suiteOrClasses) {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Monitor.java

       * finally block.
       *
       * Further optimizations of this algorithm become increasingly subtle. A wait that terminates
       * without the guard being satisfied (due to timeout, but not interrupt) can then immediately exit
       * the monitor without signalling. If it timed out without being signalled, it does not need to
       * "pass on" the signal to another thread. If it *was* signalled, then its guard must have been
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
  3. 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)
  4. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      //         for (int i = 0; i < iters; ++i) {
      //             junit.textui.TestRunner.run(s);
      //             System.gc();
      //             System.runFinalization();
      //         }
      //         System.exit(0);
      //     }
    
      //     public static TestSuite newTestSuite(Object... suiteOrClasses) {
      //         TestSuite suite = new TestSuite();
      //         for (Object suiteOrClass : suiteOrClasses) {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

              // So if value changed (and it did since we lost the CAS), then it cannot be null and
              // since it isn't a SetFuture, then the future must be done and we should exit the loop
              break;
            }
          }
        }
        return rValue;
      }
    
      /**
       * Subclasses can override this method to implement interruption of the future's computation. The
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. android/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 May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *         }
     *         public void failure(Service service) {
     *           // Something failed, at this point we could log it, notify a load balancer, or take
     *           // some other action.  For now we will just exit.
     *           System.exit(1);
     *         }
     *       },
     *       MoreExecutors.directExecutor());
     *
     *     Runtime.getRuntime().addShutdownHook(new Thread() {
     *       public void run() {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 30.5K bytes
    - Viewed (0)
Back to top