azkaban源码解读工作流状态Status(一)
2015-08-10 22:43
309 查看
工作流Status状态枚举:
- READY
- PREPARIN
- RUNNING
- PAUSED
- SUCCEEDED
- KILLED
- FAILED
- FAILED_FINISHING
- SKIPPED
- DISABLED
- QUEUED
- FAILED_SUCCEEDED
- CANCELLED
其中,绿色代表完成态;红色代表运行态。
BlockingStatus——一种阻塞在非完成态的状态封装类
public Status blockOnFinishedStatus() { if (status == null) { return null; } //如果当前job状态为非完成态,则一直阻塞 while (!Status.isStatusFinished(status)) { synchronized (this) { try { this.wait(WAIT_TIME); } catch (InterruptedException e) { } } } return status; } //释放锁,唤醒一个等待者 public void unblock() { synchronized (this) { this.notifyAll(); } } public void changeStatus(Status status) { synchronized (this) { this.status = status; if (Status.isStatusFinished(status)) { unblock(); } } }
阅读更多
相关文章推荐
- 源码编译apache实现CGI,虚拟主机,httpds安全访问,status服务状态信息,压缩等功能。
- azkaban源码解读
- 解读show slave status 命令判断MySQL复制同步状态
- Flink-CEP论文与源码解读之状态与状态转换
- azkaban源码解读(二):观察者模式在job执行过程中事件监听应用
- jpcsp源码解读8:cpu状态
- 详细解读Oracle用户ACCOUNT_STATUS的九种状态
- 【转】【用户状态】详细解读Oracle用户ACCOUNT_STATUS的九种状态
- 状态状态机Qwt源码解读之QwtPickerMachine类
- azkaban源码解读
- underscore.js 解读(敲源码)
- AFNetworking 3.0 源码解读(五)之 AFURLSessionManager
- jQuery3.2.1 源码 解读
- SEDA源码解读(三)
- jquery插件select2源码解读(三) options
- Netty学习之旅----ByteBuf源码解读之初探UnpooledHeapByteBuf、UnpooledDirectByteBuf
- 菜鸡caffe源码学习之caffe softmax源码解读
- xmlHttp.status的值(HTTP状态表)
- JVM源码分析之javaagent原理完全解读--转
- Volley源码解读