Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for Manager (0.16 sec)

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

        ServiceManager manager = new ServiceManager(asList(a, b));
        RecordingListener listener = new RecordingListener();
        manager.addListener(listener, directExecutor());
        assertState(manager, Service.State.NEW, a, b);
        assertFalse(manager.isHealthy());
        manager.startAsync().awaitHealthy();
        assertState(manager, Service.State.RUNNING, a, b);
        assertTrue(manager.isHealthy());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        ServiceManager manager = new ServiceManager(asList(a, b));
        RecordingListener listener = new RecordingListener();
        manager.addListener(listener, directExecutor());
        assertState(manager, Service.State.NEW, a, b);
        assertFalse(manager.isHealthy());
        manager.startAsync().awaitHealthy();
        assertState(manager, Service.State.RUNNING, a, b);
        assertTrue(manager.isHealthy());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *
     * <pre>{@code
     * class Server {
     *   public static void main(String[] args) {
     *     Set<Service> services = ...;
     *     ServiceManager manager = new ServiceManager(services);
     *     manager.addListener(new Listener() {
     *         public void stopped() {}
     *         public void healthy() {
     *           // Services have been initialized and are healthy, start accepting requests...
    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)
  4. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      /**
       * Runs Runnable r with a security policy that permits precisely the specified permissions. If
       * there is no current security manager, the runnable is run twice, both with and without a
       * security manager. We require that any security manager permit getPolicy/setPolicy.
       */
      public void runWithPermissions(Runnable r, Permission... permissions) {
        SecurityManager sm = System.getSecurityManager();
    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)
  5. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      /**
       * Runs Runnable r with a security policy that permits precisely the specified permissions. If
       * there is no current security manager, the runnable is run twice, both with and without a
       * security manager. We require that any security manager permit getPolicy/setPolicy.
       */
      public void runWithPermissions(Runnable r, Permission... permissions) {
        SecurityManager sm = System.getSecurityManager();
    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)
  6. android/pom.xml

            <!--
                In order to build and run the tests against JDK 18+, we need to pass java.security.manager=allow, to make
                the deprecated 'java.lang.SecurityManager' available for use.
             -->
            <jdk>[18,]</jdk>
          </activation>
          <properties>
            <test.add.args>-Djava.security.manager=allow</test.add.args>
          </properties>
        </profile>
      </profiles>
    XML
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Mar 12 20:26:18 GMT 2024
    - 19.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

          return false;
        }
      }
    
      /**
       * Creates a thread using {@link #platformThreadFactory}, and sets its name to {@code name} unless
       * changing the name is forbidden by the security manager.
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      static Thread newThread(String name, Runnable runnable) {
        checkNotNull(name);
        checkNotNull(runnable);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          RunnableExecutorPair(Runnable runnable, Executor executor) {
            this.runnable = runnable;
            this.executor = executor;
          }
        }
      }
    
      // A version of the list that uses compare and swap to manage the stack without locks.
      private static final class ExecutionListCAS {
        static final Logger log = Logger.getLogger(ExecutionListCAS.class.getName());
    
        private static final sun.misc.Unsafe UNSAFE;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 15:19:38 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Monitor.java

        return (timeoutNanos <= 0L) ? 0L : timeoutNanos - (System.nanoTime() - startTime);
      }
    
      /**
       * Signals some other thread waiting on a satisfied guard, if one exists.
       *
       * <p>We manage calls to this method carefully, to signal only when necessary, but never losing a
       * signal, which is the classic problem of this kind of concurrency construct. We must signal if
    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)
  10. LICENSE

          to the Licensor or its representatives, including but not limited to
          communication on electronic mailing lists, source code control systems,
          and issue tracking systems that are managed by, or on behalf of, the
          Licensor for the purpose of discussing and improving the Work, but
          excluding communication that is conspicuously marked or otherwise
    Plain Text
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 22 18:59:39 GMT 2023
    - 11.1K bytes
    - Viewed (0)
Back to top