Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 228 for ShutDown (0.14 sec)

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

          ExecutionException e = assertThrows(ExecutionException.class, () -> f.get());
          assertThat(e).hasCauseThat().isInstanceOf(TimeoutException.class);
        } finally {
          executor.shutdown();
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt

      @BeforeEach fun setUp() {
        executorService = Executors.newCachedThreadPool(threadFactory("HandshakeCertificatesTest"))
      }
    
      @AfterEach fun tearDown() {
        executorService.shutdown()
        serverSocket?.closeQuietly()
      }
    
      @Test fun clientAndServer() {
        platform.assumeNotConscrypt()
        platform.assumeNotBouncyCastle()
    
        val clientRoot =
          HeldCertificate.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. cmd/erasure-healing-common_test.go

    	defer cancel()
    
    	obj, disks, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatalf("Prepare Erasure backend failed - %v", err)
    	}
    	setObjectLayer(obj)
    	defer obj.Shutdown(context.Background())
    	defer removeRoots(disks)
    
    	type tamperKind int
    	const (
    		noTamper tamperKind = iota
    		deletePart
    		corruptPart
    	)
    
    	timeSentinel := time.Unix(1, 0).UTC()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java

                pool.execute(() -> {
                    assertEquals(result, crawlingInfoHelper.generateId(dataMap));
                    counter.incrementAndGet();
                });
            }
            pool.shutdown();
            pool.awaitTermination(10, TimeUnit.SECONDS);
            assertEquals(1000, counter.get());
        }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. architecture/networking/controllers.md

      When a filter changes and includes/removes new objects, those are automatically handled.
    * Proper syncing and shutdown logic. Checking for when an informer has fully started can be quite tricky; `kclient` automatically handles it.
    
    Under the `kclient` package, `clienttest` also provides similar interfaces meant for writing unit tests.
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Feb 09 17:41:25 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                while (count != 0) {
                    count = ComponentUtil.getThumbnailManager().generate(executorService, options.cleanup);
                    totalCount += count;
                }
                executorService.shutdown();
                executorService.awaitTermination(60, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Interrupted.", e);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/FessBoot.java

                }
            }).useTldDetect(jarName -> (jarName.contains("jstl") || jarName.contains("lasta-taglib"))).asDevelopment(isNoneEnv()).bootAwait();
        }
    
        public static void shutdown(final String[] args) {
            System.exit(0);
        }
    
        private static boolean isNoneEnv() {
            return System.getProperty("lasta.env") == null;
        }
    
        protected static int getPort() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          throw new UnsupportedOperationException();
        }
    
        @Override
        public boolean isTerminated() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public void shutdown() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public List<Runnable> shutdownNow() {
          throw new UnsupportedOperationException();
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            future.get();
          } catch (Throwable t) {
            // Ignore, we just wanted to block.
          }
          String error = errorMessage.get();
          assertNull(error, error);
        }
        executor.shutdown();
      }
    
      /**
       * He did the bash, he did the future bash The future bash, it was a concurrency smash He did the
       * bash, it caught on in a flash He did the bash, he did the future bash
       */
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  10. src/main/assemblies/files/service.bat

    	)
    )
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 6K bytes
    - Viewed (0)
Back to top