腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(859)
视频
沙龙
1
回答
具有
重试
能力
的
ThreadpoolExecutor
,
任务
多次
失败
后
关机
java
、
multithreading
、
scala
、
runnable
、
threadpoolexecutor
我需要一个线程池执行器,它需要完成确切数量(相同)
的
任务
。 它必须能够将
失败
的
任务
重新提交n次。如果任何一个
任务
失败
的
时间超过n,那么线程池应该关闭,并且不再继续处理任何其他
任务
。我尝试将我在不同答案中发现
的
两种方法结合起来-一种是通过重写
ThreadPoolExecutor
.afterExecute来重新提交
失败
的
任务
,另一种是子类化Count
浏览 34
提问于2019-05-14
得票数 0
回答已采纳
5
回答
失败
任务
与取消
任务
的
区别
hadoop
、
mapreduce
在Jobtracker web UI中,我看到了名为“
失败
/终止
任务
尝试”
的
列。 我想知道它们之间
的
区别。我猜“
失败
的
任务
”指的是经过
多次
重试
后
最终真正
失败
的
任务
(所以根本没有恢复?)而“被杀死
的
”意味着被杀死
的
任务
(由于超时等),但它们可能会被
重试
?
浏览 2
提问于2012-06-23
得票数 8
回答已采纳
1
回答
线程中断- JCIP
java
、
multithreading
-However,在p 141上,一个扩展线程
的
类已经公开了public void cancel() { interrupt(); },任何其他代码都可以调用它!!“只有实现线程中断策略
的
代码才能吞下中断请求。” 一个清晰,清晰,完整
的
代码说明了上面的两点,这就是我要找
的
。
浏览 4
提问于2018-06-27
得票数 0
1
回答
java.util.concurrent.RejectedExecutionException同时关闭SpeechClient
android
、
speech-recognition
、
google-speech-api
这是我用于初始化
的
代码。setCredentialsProvider { GoogleCredentials.fromStream(it) } }但当我打电话
的
时候$AbortPolicy.rejectedExecution(
ThreadPoolExecutor
.java:2011) at java.util.concurrent.
ThreadPoolExecutor
.reject(
ThreadPoolExecutor
.java:7
浏览 1
提问于2019-06-25
得票数 2
1
回答
用BeautifulSoup解析python中Google中
的
HTML?
python
、
google-app-engine
、
html-parsing
、
beautifulsoup
我一直在使用解析来自几个站点
的
HTML,将每个站点添加到GAE
任务
队列中。然而,
任务
队列似乎重复了两个似乎生成ApplicationError
的
任务
:日志中有5个错误,或者'NoneType‘对象没有属性'findAll'
失败
,当我在空闲生成
的
非对象上测试它时,当漂亮
的
在传递给它
的
页面中找不到任何东西时logging.error('Product table was empty')
浏览 1
提问于2011-01-20
得票数 1
回答已采纳
2
回答
重新尝试Python
的
ThreadPoolExecutor
中
失败
的
未来
python
、
concurrent.futures
我想用Python
的
concurrent.futures.
ThreadPoolExecutor
实现
重试
逻辑。我想要下列属性: 一旦工作队列
失败
,就会将新
的
未来添加到工作队列中。重新尝试
的
未来可以被再次
重试
,可以无限期地或者最高
重试
计数。。我在网上发现
的
很多现有代码基本上都是在“回合”中运行
的
,他们在最初
的
期货列表中调用as_completed,重新提交
失败
的
期货,
浏览 13
提问于2022-08-06
得票数 2
回答已采纳
1
回答
应用程序引擎
任务
是否可以获得其运行次数
的
计数?
google-app-engine
、
task-queue
我在Google App Engine中每小时运行数以千计
的
任务
,其中大约有.1%在
多次
重试
后
仍然
失败
。理想情况下,我希望他们停止尝试并退出。然而,由于应用程序引擎
的
设计,他们似乎只是在一次又一次地尝试。我知道每次执行
失败
都会有一个回退时间,但我希望它们在n次
重试
后退出。 我能以某种方式完成这件事吗?
任务
是否可以获得其运行
失败
次数
的
计数?
浏览 0
提问于2010-07-11
得票数 4
回答已采纳
2
回答
从dataframe写入新文件时出现文件已存在错误
apache-spark
、
emr
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:338) at java.util.concurrent.
ThreadPoolExecutor
$Worker.run(
ThreadPoolExecutor
.java
浏览 49
提问于2018-03-05
得票数 12
回答已采纳
1
回答
spark -
任务
失败
后
的
连续作业处理
apache-spark
、
configuration
、
pyspark
有没有办法告诉spark在单个
任务
失败
后继续执行作业?我
的
场景是这样
的
:我正在使用pyspark进行一些并行计算。我有一个由数千个
任务
组成
的
任务
(这些
任务
或多或少彼此独立--我可以允许一些
任务
失败
)。1个
任务
失败
(抛出异常),对此<e
浏览 0
提问于2016-08-18
得票数 1
回答已采纳
1
回答
在google应用程序引擎
任务
队列中
的
最大
重试
次数后处理
失败
python-2.7
、
google-app-engine
、
task-queue
我使用
的
是google python客户端,我使用
的
是google应用程序引擎
任务
队列,用于一些异步操作。对于特定
的
任务
队列,我还设置了应该
重试
任务
的
最大次数(在我
的
例子中,
重试
不太可能成功,因此我想限制它们)。 是否有一种方法可以编写一个处理程序,它可以处理即使在指定数量
的
重试
之后
任务
仍然
失败
的
情况?基本上,如果我
的<
浏览 3
提问于2017-10-27
得票数 1
2
回答
如何使用ExecutorService递归安排
任务
java
、
multithreading
、
recursion
、
threadpool
、
threadpoolexecutor
我可以在Java中以某种方式使用ExecutorService来调度递归
任务
吗?: Requirements: 从已排定
浏览 2
提问于2015-03-24
得票数 1
1
回答
Activii工作流长时间运行
任务
activiti
我使用
的
是Activti版本6.0.0。 我希望在activiti中同步执行
任务
,但我有一个长时间运行
的
任务
,可能需要20分钟才能执行。我想在我
的
控制器中快速获取流程实例id,而不考虑bpmn中
任务
的
完成,所以我在bpmn文件中添加了一个中间计时器事件"0分钟“。现在,两个进程都到达
任务
,那里有一个20分钟
的
等待事件(我使用了while循环).Now根据流程,两个进程都应该到达结束
任务
并完成它们
的<
浏览 1
提问于2018-04-21
得票数 0
2
回答
哪些错误应该重新启动网络
任务
?
ios
、
networking
、
nsurlsession
现在,我正试图为我
的
应用程序建立网络系统。我希望我
的
网络操作有
能力
在网络故障
后
重新尝试自己。这就是苹果对这种行为
的
看法(): 总是试图建立一个连接。如果由于无法到达主机而导致连接
失败
,请等待SCNetworkReachability API调用已注册
的
回调。当主机再次可达时,应用程序应在不受用户干预
的
情况下自动
重试
连接尝试(除非用户已采取某些措施取消请求,例如关闭浏览器窗口或单击“取消”
浏览 0
提问于2016-07-19
得票数 1
2
回答
如果所有
重试
都
失败
了,如何减少
任务
计数器?
google-app-engine
I 计数器来保持当前运行
的
任务
的
数量。一旦
任务
成功完成,我就会减少: taskqueue.add(url='/tasks/uploaddecrease_counter, counter_key) self.response.set_status(500) 但是我怎么知道最后一次尝试也没有减少
任务
计
浏览 0
提问于2011-08-09
得票数 0
2
回答
最佳实践beanstalkd (队列)和node.js
node.js
、
queue
、
message-queue
、
beanstalkd
我希望当工作
失败
时,在放弃工作之前再试一次。如果
任务
完成了,我想做同样
的
工作10次。那么,什么是最佳实践,储存在mongo与jobId
的
错误和成功计数,或删除和放置一个新
的
作业与一个错误和成功计数
的
身体。 我不知道我是不是很清楚?所以告诉我,非常感谢
浏览 1
提问于2015-10-17
得票数 1
回答已采纳
1
回答
工作流
的
Airflow与AWS步骤函数
airflow
、
aws-step-functions
我正在做一个项目,从亚马逊网络服务S3获取一组输入数据,对其进行预处理和分配,创建10K批处理容器,在亚马逊网络服务批处理上并行处理分配
的
数据,对数据进行后期聚合,并将其推送到S3。我已经有了来自Airflow + Batch
的
其他项目的软件模式,但还没有处理10k并行
任务
的
缩放因子。Airflow很好,因为我可以查看
失败
的
任务
,并在调试
后
重试
任务
。但是,在一个Airflow EC2实例上处理如此多
的</em
浏览 0
提问于2020-09-23
得票数 28
回答已采纳
1
回答
在两次数据处理之间,sqoop会
失败
sqoop
当Sqoop导入作业在将数据导入到RDBMS-HDFS时
失败
时会发生什么,反之亦然?
浏览 0
提问于2018-05-01
得票数 0
1
回答
如何在spark streaming中跟踪
失败
的
批处理
spark-streaming
我正在使用Kafka
的
Spark Streaming,使用直接
的
approach.Basically,当有多个
任务
失败
时,在批处理级别的某些
重试
后
,整个批处理
失败
,数据丢失。我想知道是否有任何机制来跟踪那些
具有
丢失偏移范围
的
失败
批处理,以便我可以重新处理这些丢失
的
数据。
浏览 1
提问于2018-03-10
得票数 3
1
回答
Microsoft图形api计划器
任务
大容量插入
microsoft-graph-api
、
asp.net-core-3.1
、
microsoft-graph-plannertasks
我们在计划
任务
crud操作
的
.Net核心应用程序中使用MicrosoftGraphAPIv1.0。我们正在执行
的
步骤是:在进行
多次
重试
时,我们在分组下随机得到400或500个计划,它创造了成功
的
结果。有些时候,在计划
任务
后<
浏览 3
提问于2022-11-01
得票数 0
1
回答
是否可以在meta/main.yml中执行逻辑并确定是否在Ansible中执行给定
的
角色?
ansible
Ansible
的
重试
文件没有意义,因为我在剧本中
的
多个角色正在调用一堆不同
的
API。 在多个DC设置中,一个给定
的
剧本被迭代。如果有什么事情
失败
了,并且剧本退出了,使用Ansible
的
默认
重试
文件并没有恢复到它应该恢复
的
位置。我想知道meta/main.yml是否可以以某种方式读取跟踪DC和role...maybe
的
动态状态文件,我们可以读取并确定给定角色是否可以执行。我们可以为角色
的
ma
浏览 6
提问于2022-10-29
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
JUC 之ThreadPoolExecutor实现原理分析
基于有限状态机与消息队列的三方支付系统补单实践
RabbitMQ一个简单可靠的方案
爱奇艺iOS移动端网络优化实践:请求成功率优化
【行业资讯】纯 PHP 协程框架 Wind Framework 0.1.3 发布
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券