com.supermap.services.components

类 AbstractRuntimeJobState

  • 直接已知子类:
    CloudRuntimeJobState


    public abstract class AbstractRuntimeJobState
    extends JobState
    

    运行时的切图作业状态信息类。职责包括
    1,切图任务的拆分
    2, 切图子节点任务完成或失败时,切图状态的自动更新
    3, 子节点状态管理等。

    从以下版本开始:
    6.1.3
    • 字段详细资料

      • currentState

        protected volatile JobState currentState
        
      • config

        protected JobBuildConfig config
        
      • stopped

        protected boolean stopped
        
      • changeStateLock

        protected java.util.concurrent.locks.ReentrantLock changeStateLock
        
    • 构造器详细资料

      • AbstractRuntimeJobState

        public AbstractRuntimeJobState(JobState value)
        

        构造函数。

        参数:
        value -
    • 方法详细资料

      • getInfoByScale

        protected TileScaleInfo getInfoByScale(double scaleDenominator)
        

        获取切图任务比例尺下的进度。

        参数:
        scaleDenominator -
        返回:
      • getState

        public JobState getState()
        

        获取当前所有任务状态。

        返回:
      • getTaskById

        public TileTask getTaskById(java.lang.String id)
        

        通过ID,获取的单元任务。

        参数:
        id -
        返回:
      • updateTaskToCompleted

        public abstract JobState updateTaskToCompleted(TileTask task,
                                     TileTaskBuildResult taskBuildResult,
                                     TileWorkerInfo tileWorkerInfo)
        

        更新当前的状态,以反映task已经完成。

        参数:
        task -
        返回:
        从以下版本开始:
        6.1.3
      • updateTaskToCompleted

        public abstract JobState updateTaskToCompleted(TileTask task)
        

        更新当前的状态,以反映task已经完成。

        参数:
        task -
        返回:
        从以下版本开始:
        6.1.3
      • updatElapsedTime

        protected void updatElapsedTime(JobState result)
        
      • delTask

        protected void delTask(java.lang.String id)
        
      • getTask

        public abstract TileTask getTask()
        

        获取单元任务。

        参数:
        id -
        返回:
      • getScaleBuildConfigByScale

        protected ScaleBuildConfig getScaleBuildConfigByScale(double scaleDenominator)
        
      • setConfig

        public void setConfig(JobBuildConfig value)
        

        设置切图任务配置信息。

        参数:
        value -
      • updateTaskFailed

        public JobState updateTaskFailed(TileTask task)
        

        将单元切图任务标记为失败。

        参数:
        task -
        返回:
      • stop

        public JobState stop()
        

        停止切图任务。

        返回:
      • start

        public JobState start()
        

        开始切图任务。

        返回:
      • notifyWorkerDisconnected

        public JobState notifyWorkerDisconnected(java.lang.String workerId)
        

        切图子节点连接失败时,将单元切图任务标记为失败 。

        参数:
        workerId -
        返回:
      • getAllTasks

        public java.util.List<TileTask> getAllTasks()
        

        获取单元切图任务列表。

        返回:
      • updateProgress

        public void updateProgress(java.util.Map<java.lang.String,java.lang.Long> progress)
        

        更新切图进度。

        参数:
        progress -
      • notifyLostConnectionPerhaps

        public java.util.List<java.lang.String> notifyLostConnectionPerhaps(java.util.Map<java.lang.String,TileTask> lostConnection)
        

        获取执行单元切图任务时断开连接的workID。

        参数:
        lostConnection -
        返回:
      • addUpdateTasks

        public JobState addUpdateTasks(TileTask[] updateTasks)
        

        添加单元切图任务。

        参数:
        updateTasks -
        返回:
      • setTileRegionStateManager

        public void setTileRegionStateManager(TileRegionStateManager tileRegionStateManager)
        

        设置切图范围状态管理器。

        参数:
        tileRegionStateManager -