com.alibaba.nacos.config.server.manager

Class TaskManager

java.lang.Object

com.alibaba.nacos.config.server.manager.TaskManager

All Implemented Interfaces:

TaskManagerMBean

public final class TaskManager
extends Object
implements TaskManagerMBean

用于处理一定要执行成功的任务 单线程的方式处理任务，保证任务一定被成功处理

Author:

huali

Constructor Summary

Constructors

Constructor and Description
TaskManager()
TaskManager(String name)

Method Summary

Modifier and Type	Method and Description
void	addProcessor(String type, TaskProcessor taskProcessor)
void	addTask(String type, AbstractTask task) 将任务加入到任务Map中
void	await()
boolean	await(long timeout, TimeUnit unit)
void	close()
TaskProcessor	getDefaultTaskProcessor()
AbstractTask	getTask(String type)
String	getTaskInfos() get task info
TaskProcessor	getTaskProcessor(String type)
void	init()
boolean	isEmpty()
protected void	process()
void	removeProcessor(String type)
void	removeTask(String type)
void	setDefaultTaskProcessor(TaskProcessor defaultTaskProcessor)
int	size()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskManager

public TaskManager()

TaskManager

public TaskManager(String name)

Method Detail

getTask

public AbstractTask getTask(String type)

getTaskProcessor

public TaskProcessor getTaskProcessor(String type)

size

public int size()

close

public void close()

await

public void await()
           throws InterruptedException

Throws:

InterruptedException

await

public boolean await(long timeout,
                     TimeUnit unit)
              throws InterruptedException

Throws:

InterruptedException

addProcessor

public void addProcessor(String type,
                         TaskProcessor taskProcessor)

removeProcessor

public void removeProcessor(String type)

removeTask

public void removeTask(String type)

addTask

public void addTask(String type,
                    AbstractTask task)

将任务加入到任务Map中

Parameters:

type -

task -

process

protected void process()

isEmpty

public boolean isEmpty()

getDefaultTaskProcessor

public TaskProcessor getDefaultTaskProcessor()

setDefaultTaskProcessor

public void setDefaultTaskProcessor(TaskProcessor defaultTaskProcessor)

getTaskInfos

public String getTaskInfos()

Description copied from interface: TaskManagerMBean

get task info

Specified by:

getTaskInfos in interface TaskManagerMBean

Returns:

info

init

public void init()