java 自定义 钩子_Java添加关闭钩子里面的方法

在我的代码中,我使用CompletionService和ExecutorService来启动一堆Thread来执行某些任务(这可能需要很长时间) . 所以我有一个创建ExecutorService和CompletionService的方法,然后开始提交线程然后获取结果 . 我想添加一个关闭钩子,以便优雅地关闭执行程序(我知道可能我应该处理释放资源而不是 Actuator 关闭但在我的情况下每个线程都有自己的资源,所以优雅地关闭它们可以是一个很好的解决方案我假设) .

因此我编写以下代码

public Class myClass{

...

private CompletionService completion;

final long SHUTDOWN_TIME = TimeUnit.SECONDS.toSeconds(10);

...

public Message executeCommand(Message request){

final ExecutorService executor = Executors.newFixedThreadPool(30);

completion = new ExecutorCompletionService(executor);

....//submit and take results

Runtime.getRuntime().addShutdownHook(new Thread(){

@Override

public void run() {

logger.debug("Shutting down executor");

try {

if (!executor.awaitTermination(SHUTDOWN_TIME, TimeUnit.SECONDS)) {

logger.debug("Executor still not terminate after waiting time...");

List notExecuted= executor.shutdownNow();

logger.debug("List of dropped task has size " + droppedTasks.size());

}

}catch(InterruptedException e){

logger.error("",e);

}

}

});

}

}

您认为这是一个合理的解决方案,还是使用本地类注册和取消注册关闭钩子是不安全的?

提前致谢

问候

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/567959.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Ubuntu nginx+uwsgi部署Django项目

前提条件:首先项目使用一下命令启动成功后,输入公网ip后可以启动成功 python manage.py runserver 0.0.0.0:80 一、阿里云配置安全组 添加8000端口 二、安装配置uwsgi 1、确定django项目可以正常运行了,ctrlc停止项目,下面我们来…

STL7-基础

1、容器可以嵌套容器 2、容器分为序列式容器和关联式容器 序列式容器:容器的元素的位置是由进入容器时机和地点来决定 关联式容器:容器已经有规则,进入容器的元素的位置不是由进入容器时机和地点来决定 只与此容器的排列规则有关 3、迭代…

java 0xaarrggbb 转换_RRGGBBAA或者RRGGBB转换成rgba()

//十六进制颜色值的正则表达式var reg /^#([0-9a-fA-f]{3}|[0-9a-fA-f]{6})$/;/*16进制颜色转为RGB格式*/var colorRgb function(color){if(color.length>7){var num color.slice(7,9).toUpperCase();var x opacityColor(num)color color.slice(0,7);}var sColor color…

java 假设当前时间_Java中与日期和时间相关的类和方法

一、currentTimeMillis()方法System 类中的方法 currentTimeMillis() 方法可以返回从 GMT1970 年 1 月 1 日 00 : 00 : 00 开始到当前时刻的毫秒数。System.currentTimeMillis(); //返回值为long类型二、Date类1.构造方法(1)public Date (); 以当前系统时间创建一个Date对象&am…

STL8-string容器

C 没有 string 类&#xff0c;但提供了直接对字符数组、字符串操作的函数 -> 如 str_len()等等 -> 需要包含 “string.h”#include<iostream> #include<string> using namespace std;//初始化 void test01() {string s1; //调用无参构造string s2(10, a);str…

java 采集 cms_开源 java CMS - FreeCMS2.3 Web页面信息采集

Web页面信息采集从FreeCMS 2.1开始支持通过简单配置即可抓取目标网页信息&#xff0c;支持增量式采集、关键字替换、定时采集&#xff0c;同一采集规则可采集多个页面(静态和动态)&#xff0c;可采集多种信息属性&#xff0c;可自动审核且静态化信息页面。采集规则管理从左侧管…

Python中reshape函数参数-1的意思?

import numpy as np c np.array([[1,2,3],[4,5,6]]) print(2行3列) print(c.reshape(2,3)) print(3行2列) print(c.reshape(3,2)) print(我也不知道几行&#xff0c;反正是一列) print(c.reshape(-1,1)) print(我也不知道几列&#xff0c;反正是一行) print(c.reshape(1,-1)) …

java浮点数四舍五入_Java小程序练习--浮点数的四舍五入

今天学习到了关于浮点数的知识&#xff0c;而后便编写了一个小demo&#xff0c;实现浮点数的四舍五入&#xff0c;保留两位小数。具体实现思路如下:1.获取用户输入的数字&#xff0c;将其保存到double型变量中&#xff1b;2.因为要保存到小数点后的两位&#xff0c;将该数乘以1…

STL9-vector容器

vector容器 动态数组 可变数组 vector容器 单口容器 vector实现动态增长&#xff1a; 当插入新元素时&#xff0c;如果空间不足&#xff0c;那么vector会重新申请更大内存空间&#xff08;默认二倍&#xff09;&#xff0c;将原空间数据拷贝到新空间&#xff0c;释放旧空…

函数返回值失效

#include<stdio.h> #include<stdlib.h> #include<string.h> #if 1 char* getMen2() {char buf[64]; //临时变量&#xff0c;栈区存放strcpy(buf, "abccddeeff");printf("buf:%s\n", buf);return buf; //此处并不是把内存块64个字节ret…

mysql突然出现慢sql_Mysql开启慢SQL并分析原因

第一步.开启mysql慢查询方式一:修改配置文件Windows&#xff1a;Windows 的配置文件为 my.ini&#xff0c;一般在 MySQL 的安装目录下或者 c:\Windows 下。Linux&#xff1a;Linux 的配置文件为 my.cnf &#xff0c;一般在 /etc 下在 my.ini 增加几行:[mysqlld]long_query_time…

STL10-deque容器

deque 双端队列 deque 删除操作 deque案例&#xff1a; #if 1 #include<iostream> #include<deque> using namespace std; void PrintDeque(deque<int>& d) {for (deque<int>::iterator it d.begin(); it ! d.end(); it) {cout << *it <…

php mysql 平均分_平均评级计算mysql php

我想计算每个用户的平均评分 .我有三张 table .表评级id |order_id |rate------------------1 | 52 |82 | 51 |43 | 52 |24 | 51 |7表顺序这里做的是驱动程序表IDid |did------------------52 | 551 | 735 | 644 | 8表驱动程序id |name------------------5 | test17 | test28 |…

Leedcode4-sort listnode 归并排序

#include<iostream> using namespace std;//Sort a linked list in O(n log n) time using constant space complexity.//Definition for singly-linked list. //归并排序 #if 0 struct ListNode {int val;ListNode *next;ListNode(int x) : val(x), next(NULL) {}}; str…

vue 字典配置_vue遍历数据及字典的方法

数组&#xff1a;数值{{ item.message }}数组&#xff1a;数值加索引{{ item.msg }}{{index}}字典&#xff1a;key value index{{ value }} {{key}} {{index}}new Vue({el: #repeat,data: {object: {FirstName: John,LastName: Doe,Age: 30}}})vue遍历数组和对象的方法以及他们…

tensorflow代码中tf.app.run()什么意思

# 前面的代码省略了... 。。。 。。。 。。。 def main(argvNone):mnist input_data.read_data_sets("F:\mydata\TensorFlowData\MNIST_data", one_hotTrue)train(mnist)if __name__ __main__:tf.app.run()那么 tf.app.run()什么意思呢 &#xff1f;可以猜到&#…

java jdbc dao_Java自学-JDBC DAO

基于JDBC设计DAO的实例DAODataAccess Object数据访问对象实际上就是运用了ORM中的思路&#xff0c;把数据库相关的操作都封装在这个类里面&#xff0c;其他地方看不到JDBC的代码步骤 1 : DAO接口package jdbc;import java.util.List;import charactor.Hero;public interface DA…

java 井字棋 人机_一个井字棋tictactoe游戏的java实现 | Soo Smart!

这是一个井字棋游戏的java实现。摘录于stackoverflow。游戏规则很简单&#xff0c;只要一方棋子在水平线&#xff0c;垂直线或者对角线任意一条线上排列成功即为获胜。作者原先的代码存在着一些问题&#xff1a;代码如下&#xff1a;一共有几个类: play, player, human, comput…

C++随机数(rand和srand)函数用法详解

C 提供了一组函数以生成和使用随机数字。随机数字就是从一组可能的值中进行随机选择而获得的一个值。该组中的值都有相同的被选中的几率。 随机数字常用于许多不同类型的程序中&#xff0c;以下是一些示例&#xff1a; 计算机游戏通常要使用随机数字来模拟一些随机过程&#x…

STL11-stack容器

#if 1 #include<iostream> #include<stack> using namespace std;void test01() {//初始化stack<int> s1;stack<int> s2(s1);//stack操作s1.push(10);s1.push(20);s1.push(30);s1.push(40);cout << "栈顶元素&#xff1a;" << e…