exec=Executors.newFixedThreadPool(1)
Callable<String>call = new Callable<String>() {
public String call() throws Exception {
//开始 *** 作
//TimeTaskTest.star(null)
return "线程执行完成"
}
}
Future<String>future = exec.submit(call)
//设置为30分钟超时
future.get(1000*60*time , TimeUnit.MILLISECONDS)
=========================================
如果你是在进行其他 *** 作的话那就比较麻烦了,目前我想到的是在子线程中一直访问某个变量,超时时守护线程改变这个值,然后子线程读到后退出,不过这个有个问题,就是当子线程卡死在某个环节时完全无用
Hystrix所有的配置都是 hystrix.command.[HystrixCommandKey] 开头,其中 [HystrixCommandKey] 是可变的,默认是 default ,即 hystrix.command.default ;另外Hystrix内置了默认参数,如果没有配置Hystrix属性,默认参数就会被设置,其优先级:
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds 用来设置thread和semaphore两种隔离策略的超时时间,默认值是1000。
这个超时时间要根据 CommandKey 所对应的业务和服务器所能承受的负载来设置,要根据 CommandKey 业务的平均响应时间设置,一般是大于平均响应时间的 20%~100% ,最好是根据压力测试结果来评估,这个值设置太大,会导致线程不够用而会导致太多的任务被fallback;设置太小,一些特殊的慢业务失败率提升,甚至会造成这个业务一直无法成功,在重试机制存在的情况下,反而会加重后端服务压力。
这个值并非 TPS 、 QPS 、 RPS 等都是相对值,指的是1秒时间窗口内的事务/查询/请求, semaphore.maxConcurrentRequests 是一个绝对值,无时间窗口,相当于亚毫秒级的,指任意时间点允许的并发数。当请求达到或超过该设置值后,其其余就会被拒绝。默认值是100。
是否开启超时,默认是true,开启。
发生超时是是否中断线程,默认是true。
取消时是否中断线程,默认是false。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)