java怎么使用quartz任务调度传一些集合数组

Python014

java怎么使用quartz任务调度传一些集合数组,第1张

可以使用JobDataMap来传递集合数组,JobDataMap是Quartz提供的一个Map,可以用来存储任务相关的数据。

在调度任务时,可以使用JobDataMap来传递集合数组:

JobDetail jobDetail = newJob(MyJob.class)

.withIdentity("myJob", "group1")

.usingJobData("myCollection", myCollection)

.build()

// 在任务中获取集合数组

@Override

public void execute(JobExecutionContext context) throws JobExecutionException {

JobDataMap dataMap = context.getJobDetail().getJobDataMap()

List<String>myCollection = (List<String>) dataMap.get("myCollection")

// do something with myCollection

}

在应用里经常都有用到在后台跑定时任务的需求。举个例子,比如需要在服务后台跑一个定时任务来进行非实时计算,清除临时数据、文件等。在本文里,3种不同的实现方法: 普通thread实现 TimerTask实现 ScheduledExecutorService实现

公众:类PrivilegeProcess {

公共静态无效的主要(字串[] args){

MyQueue的MyQueue的新MyQueue的()/ /声明队列

印刷电路板[PCB = {新的PCB(001 ,8,1),新的PCB(002,7,9),新的PCB(003,3,8),新的PCB(004,1,7),新的PCB(005,7,4)}

>PCB段=新的PCB()

(INT I = 0<pcb.length+ +){/ /初始化先进行排序,选择排序这里使用的是高优先级的一线队

(J =我<pcb.lengthJ + +){

(PCB [I]。特权<PCB [J]。特权){

段= PCB [1]

PCB [I] = PCB [J]

PCB [J] =段

}

}

}

体系。通过out.println(“入队后第一时间的进程的顺序:”)

(INT I = 0<pcb.length+ +){

的System.out调用println(第一次入队#程序名称:“+ PCB [我]。名称+ totaltime:”+ PCB [I]。totaltime +“的”特权“+ PCB [我]。特权)}

()

myqueue.start(PCB)

}

}

类MyQueue的{

INT指数= 0

PCB [] PC =新的PCB [5]

PCB [] PC1 =新的PCB [4]

PCB温度=新的PCB() BR />公共无效排队(PCB工艺){/ /排队算法

(指数== 5){

(“出界!”)

返回

}

PC [索引] =进程

指数+ +

}

公共:PCB DEQUEUE(){/ /出队算法(索引== 0)

返回空

(INT I = 0<pc1.length+ +){

PC1 [I] = PC [ +1]

}

指数 -

温度= PC [0]

(INT I = 0<pc1.length+ +){ BR />PC [I] = PC1 [I]

}

回报条件

}

公共无效启动(PCB [] PC){/ /进程表算法

(PC [0]。isNotFinish ==真| | PC [1 isNotFinish ==真| | PC [2 isNotFinish ==真| | PC [3]。时isNotFinish ==真| | PC [4]。isNotFinish ==){

/ / *注:| |运算符都是假的,所有的表达式结果为假,否则真

(INT I = 0<PC长度+ +){

PC [I]。运行(这一点)/>} 的System.out.println()

(INT I = 0<pc.length+ +){/ /处理每个运行一次运行的时间片的长度重新排序优先一旦

(J =我<pc.lengthJ + +){

如果(PC [I]特权<PC [J]。特权){

温度= PC [I]

PC [I] = PC [J]

PC [J] =温度

}

}

}

}

}

}

类PCB {/ /声明过程级

和int名,totaltime ,运行时特权

布尔isNotFinish的

公众PCB(){

}

公开PCB(名称,诠释totaltime特权){

this.name =的名称/ /进程名

this.totaltime = totaltime / /

this.privilege =特权/ /总时间优先 this.runtime = 2 / /时间片值是2

this.isNotFinish =真/ /是否执行完成

(“初始值:程序名称:”+名+“totaltime:”+ totaltime +“特权”+特权)

System.out的。调用println()

}

MyQueue的MQ公共无效的run(){/ /处理的基础上实施的时间片算法

(totalTime>1){ totaltime =运行/ /总时间大于1,总时间=总时间 - 时间片

特权 -

(“程序名称:”+姓名+“ remaintime:“+ +”特权“+特权)totaltime

的} else if(totaltime == 1){

totaltime - / /总时间为1时,执行时间为1

>特权 -

(“程序名称:”+姓名+“remaintime:”+ totaltime +“特权”+特权)

}其他{

isNotFinish =假/ / 0,将isNotFinish标志设置为假

}

如果(isNotFinish ==真){br mq.deQueue() mq.enQueue(本)}

}

}