Azkaban的线程系列 38:ExecutorManagerUpdaterThread
Azkaban的线程系列 38:ExecutorManagerUpdaterThread
强子哥哥 发表于2年前
Azkaban的线程系列 38:ExecutorManagerUpdaterThread
  • 发表于 2年前
  • 阅读 167
  • 收藏 0
  • 点赞 1
  • 评论 0

移动开发云端新模式探索实践 >>>   

ExecutorManagerUpdaterThread线程如何运行?主要是获取

当前运行的flow的状态!

相关的几种操作有

public static final String UPDATE_ACTION = "update";

  public static final String STATUS_ACTION = "status";

  public static final String EXECUTE_ACTION = "execute";

  public static final String CANCEL_ACTION = "cancel";

  public static final String PAUSE_ACTION = "pause";

  public static final String RESUME_ACTION = "resume";

拿一个例子来说,如何pause?

public void pauseFlow(int execId, String user) throws ExecutorManagerException {

FlowRunner runner = runningFlows.get(execId);

 

if (runner == null) {

throw new ExecutorManagerException("Execution " + execId + " is not running.");

}

 runner.pause(user);

}

那么,flowRunner如何执行pause操作呢?

就是设置一个变量,然后不停循环查看变量的值

===================================================================================

关于如何取消一个任务见 

azkaban.jobExecutor.ProcessJob.cancel()

 


标签: azkaban
  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
强子哥哥
粉丝 850
博文 551
码字总数 648643
作品 8
×
强子哥哥
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: