io.grpc.Server.shutdown()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(4.3k)|赞(0)|评价(0)|浏览(142)

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

Server.shutdown介绍

[英]Initiates an orderly shutdown in which preexisting calls continue but new calls are rejected.
[中]启动有序关机,其中先前存在的呼叫继续,但新呼叫被拒绝。

代码示例

代码示例来源:origin: google/rejoiner

private void stop() {
 if (server != null) {
  server.shutdown();
 }
}

代码示例来源:origin: Alluxio/alluxio

/**
 * Shuts down the server.
 *
 * @return {@code true} if the server was successfully terminated.
 * @throws InterruptedException
 */
public boolean shutdown() {
 mServer.shutdown();
 try {
  return mServer.awaitTermination(mServerShutdownTimeoutMs, TimeUnit.MILLISECONDS);
 } catch (InterruptedException ie) {
  Thread.currentThread().interrupt();
  return false;
 } finally {
  mServer.shutdownNow();
 }
}

代码示例来源:origin: google/rejoiner

private void stop() {
 if (server != null) {
  server.shutdown();
 }
}

代码示例来源:origin: google/rejoiner

private void stop() {
 if (server != null) {
  server.shutdown();
 }
}

代码示例来源:origin: google/rejoiner

private void stop() {
 if (server != null) {
  server.shutdown();
 }
}

代码示例来源:origin: google/rejoiner

private void stop() {
 if (server != null) {
  server.shutdown();
 }
}

代码示例来源:origin: Netflix/conductor

@Override
  public void stop() {
    if (server != null) {
      logger.info("grpc: server shutting down");
      server.shutdown();
    }
  }
}

代码示例来源:origin: weibocom/motan

/**
 * remove service specified by url.
 * the server will be closed if all service is remove 
 * @param url
 */
public void safeRelease(URL url){
  synchronized (serviceDefinetions) {
    registry.removeService(serviceDefinetions.remove(url));
    if(httpHandler != null){
      httpHandler.removeProvider(url);
    }
    if(serviceDefinetions.isEmpty()){
      server.shutdown();
      if(executor != null){
        executor.shutdownNow();
      }
    }
  }
}

代码示例来源:origin: mrdear/JavaWEB

/**
 * 关闭服务
 */
public void stop() {
  if (server != null) {
    server.shutdown();
  }
}

代码示例来源:origin: mrdear/JavaWEB

private void stop() {
  if (server != null) {
    server.shutdown();
  }
}

代码示例来源:origin: GoogleCloudPlatform/java-docs-samples

private void stop() {
 if (server != null) {
  server.shutdown();
 }
}

代码示例来源:origin: mrdear/JavaWEB

private void stop() {
  if (server != null) {
    server.shutdown();
  }
}

代码示例来源:origin: yidongnan/grpc-spring-boot-starter

/**
 * Initiates an orderly shutdown of the grpc server and releases the references to the server. This call does not
 * wait for the server to be completely shut down.
 */
protected void stopAndReleaseGrpcServer() {
  factory.destroy();
  Server localServer = this.server;
  if (localServer != null) {
    localServer.shutdown();
    this.server = null;
    log.info("gRPC server shutdown.");
  }
}

代码示例来源:origin: glowroot/glowroot

@Override
  public @Nullable Void call() throws Exception {
    server.shutdown();
    if (!server.awaitTermination(10, SECONDS)) {
      throw new IllegalStateException("Could not terminate channel");
    }
    executor.shutdown();
    if (!executor.awaitTermination(10, SECONDS)) {
      throw new IllegalStateException("Could not terminate executor");
    }
    if (!bossEventLoopGroup.shutdownGracefully(0, 0, SECONDS).await(10, SECONDS)) {
      throw new IllegalStateException(
          "Could not terminate gRPC boss event loop group");
    }
    if (!workerEventLoopGroup.shutdownGracefully(0, 0, SECONDS).await(10, SECONDS)) {
      throw new IllegalStateException(
          "Could not terminate gRPC worker event loop group");
    }
    socketHeartbeat.close();
    return null;
  }
});

代码示例来源:origin: TFdream/rpc-framework-tutorials

private void stop() {
  if (server != null) {
    server.shutdown();
  }
}

代码示例来源:origin: locationtech/geowave

/** Stop serving requests and shutdown resources. */
public void stop() {
 if (server != null) {
  server.shutdown();
 }
}

代码示例来源:origin: opencb/cellbase

private void stop() {
  if (server != null) {
    server.shutdown();
  }
}

代码示例来源:origin: io.vertx/vertx-grpc

void stop(ContextInternal context, Handler<AsyncResult<Void>> completionHandler) {
 boolean shutdown = count.decrementAndGet() == 0;
 context.runOnContext(v -> {
  manager.removeHandler("foo", context);
  contextLocal.get().remove(context);
  if (shutdown) {
   map.remove(id);
   server.shutdown();
  }
  completionHandler.handle(Future.succeededFuture());
 });
}

代码示例来源:origin: census-instrumentation/opencensus-java

@After
public void tearDown() {
 if (!server.isTerminated()) {
  server.shutdown();
 }
}

代码示例来源:origin: sitewhere/sitewhere

@Override
public void stop(ILifecycleProgressMonitor monitor) throws SiteWhereException {
getServer().shutdown();
try {
  getServer().awaitTermination();
  getLogger().debug("GRPC server terminated successfully.");
} catch (InterruptedException e) {
  getLogger().error("Interrupted while waiting for GRPC server to terminate.", e);
}
}

相关文章