本文整理了Java中io.grpc.Server.shutdown()
方法的一些代码示例,展示了Server.shutdown()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Server.shutdown()
方法的具体详情如下:
包路径:io.grpc.Server
类名称: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!