本文整理了Java中org.uberfire.java.nio.file.WatchService.close()方法的一些代码示例，展示了WatchService.close()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WatchService.close()方法的具体详情如下：
包路径：org.uberfire.java.nio.file.WatchService
类名称：WatchService
方法名：close

WatchService.close介绍

暂无

代码示例

代码示例来源：origin: kiegroup/appformer

@PreDestroy
private void shutdown() {
  executorService.shutdown();
  active = false;
  if (ws != null) {
    ws.close();
  }
}

代码示例来源：origin: org.uberfire/uberfire-metadata-commons-io

@Override
public void dispose() {
  watchServicesByFS.values()
           .forEach(ws -> ws.close());
  activeIndexerDispatchers.forEach(d -> d.dispose());
  super.dispose();
}

代码示例来源：origin: kiegroup/appformer

@Override
public void dispose() {
  watchServicesByFS.values()
           .forEach(ws -> ws.close());
  activeIndexerDispatchers.forEach(d -> d.dispose());
  super.dispose();
}

代码示例来源：origin: kiegroup/appformer

@PreDestroy
protected void dispose() {
  isDisposed = true;
  for (final WatchService watchService : watchServices) {
    watchService.close();
  }
  for (final Future<?> job : jobs) {
    if (!job.isCancelled() && !job.isDone()) {
      job.cancel(true);
    }
  }
  executorService.shutdown(); // Disable new tasks from being submitted
  try {
    // Wait a while for existing tasks to terminate
    if (!executorService.awaitTermination(AWAIT_TERMINATION_TIMEOUT,
                       TimeUnit.SECONDS)) {
      executorService.shutdownNow(); // Cancel currently executing tasks
      // Wait a while for tasks to respond to being cancelled
      if (!executorService.awaitTermination(AWAIT_TERMINATION_TIMEOUT,
                         TimeUnit.SECONDS)) {
        LOG.error("Thread pool did not terminate");
      }
    }
  } catch (InterruptedException ie) {
    // (Re-)Cancel if current thread also interrupted
    executorService.shutdownNow();
    // Preserve interrupt status
    Thread.currentThread().interrupt();
  }
}

代码示例来源：origin: org.guvnor/guvnor-structure-backend

watchService.close();

代码示例来源：origin: kiegroup/appformer

watchService.close();

代码示例来源：origin: org.uberfire/uberfire-metadata-commons-io

private void cleanupDeletedFS(FileSystem fs) {
  WatchService ws = watchServicesByFS.remove(fs.getName());
  if (ws != null && !ws.isClose()) {
    ws.close();
  }
  fs.getRootDirectories().forEach(rootPath -> indexEngine.delete(KObjectUtil.toKCluster(rootPath)));
}

代码示例来源：origin: kiegroup/appformer

private void cleanupDeletedFS(FileSystem fs) {
  WatchService ws = watchServicesByFS.remove(fs.getName());
  if (ws != null && !ws.isClose()) {
    ws.close();
  }
  fs.getRootDirectories().forEach(rootPath -> indexEngine.delete(KObjectUtil.toKCluster(rootPath)));
}

代码示例来源：origin: org.uberfire/uberfire-metadata-commons-io

@Test
public void recreatingFileSystemMakesNewWatchService() throws Exception {
  URI uri = new URI("test:///some/path");
  Map<String, ?> env = Collections.emptyMap();
  FileSystem fs1 = ioService.newFileSystem(uri, env);
  verify(fs1).newWatchService();
  FSPath fsPath = mock(FSPath.class);
  when(fsPath.getFileSystem()).thenReturn(fs1);
  ioService.delete(fsPath);
  verify(fs1.newWatchService()).close();
  FileSystem fs2 = ioService.newFileSystem(uri, env);
  // Stubs are reused so this will have been invoked one above in IOService, and once in this test in a verify method.
  verify(fs2, times(3)).newWatchService();
}

代码示例来源：origin: kiegroup/appformer

@Test
public void recreatingFileSystemMakesNewWatchService() throws Exception {
  URI uri = new URI("test:///some/path");
  Map<String, ?> env = Collections.emptyMap();
  FileSystem fs1 = ioService.newFileSystem(uri, env);
  verify(fs1).newWatchService();
  FSPath fsPath = mock(FSPath.class);
  when(fsPath.getFileSystem()).thenReturn(fs1);
  ioService.delete(fsPath);
  verify(fs1.newWatchService()).close();
  FileSystem fs2 = ioService.newFileSystem(uri, env);
  // Stubs are reused so this will have been invoked one above in IOService, and once in this test in a verify method.
  verify(fs2, times(3)).newWatchService();
}