?? loadexample.java
字號:
/* * Copyright 2005 OpenSymphony * * Licensed under the Apache License, Version 2.0 (the "License"); you may not * use this file except in compliance with the License. You may obtain a copy * of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. * */package org.quartz.examples.example11;import java.util.Date;import org.quartz.JobDetail;import org.quartz.Scheduler;import org.quartz.SchedulerFactory;import org.quartz.SchedulerMetaData;import org.quartz.SimpleTrigger;import org.quartz.impl.StdSchedulerFactory;import org.apache.commons.logging.LogFactory;import org.apache.commons.logging.Log;/** * This example will spawn a large number of jobs to run * * @author James House, Bill Kratzer */public class LoadExample { private int _numberOfJobs = 500; public LoadExample(int inNumberOfJobs) { _numberOfJobs = inNumberOfJobs; } public void run() throws Exception { Log log = LogFactory.getLog(LoadExample.class); // First we must get a reference to a scheduler SchedulerFactory sf = new StdSchedulerFactory(); Scheduler sched = sf.getScheduler(); log.info("------- Initialization Complete -----------"); log.info("------- (Not Scheduling any Jobs - relying on XML definitions --"); String schedId = sched.getSchedulerInstanceId(); // schedule 500 jobs to run for (int count=1; count <= _numberOfJobs; count++) { JobDetail job = new JobDetail("job" + count, "group1", SimpleJob.class); // tell the job to wait one minute (60 seconds) job.getJobDataMap().put(SimpleJob.DELAY_TIME, 60000L); // ask scheduler to re-execute this job if it was in progress when // the scheduler went down... job.setRequestsRecovery(true); SimpleTrigger trigger = new SimpleTrigger("trigger_" + count, "group_1"); trigger.setStartTime(new Date(System.currentTimeMillis() + 10000L + (count * 100))); sched.scheduleJob(job, trigger); if (count % 25 == 0) { log.info("...scheduled " + count + " jobs"); } } log.info("------- Starting Scheduler ----------------"); // start the schedule sched.start(); log.info("------- Started Scheduler -----------------"); log.info("------- Waiting five minutes... -----------"); // wait five minutes to give our jobs a chance to run try { Thread.sleep(300L * 1000L); } catch (Exception e) { } // shut down the scheduler log.info("------- Shutting Down ---------------------"); sched.shutdown(true); log.info("------- Shutdown Complete -----------------"); SchedulerMetaData metaData = sched.getMetaData(); log.info("Executed " + metaData.numJobsExecuted() + " jobs."); } public static void main(String[] args) throws Exception { int numberOfJobs = 500; if (args.length == 1) { numberOfJobs = Integer.parseInt(args[0]); } if (args.length > 1) { System.out.println( "Usage: java " + LoadExample.class.getName() + "[# of jobs]"); return; } LoadExample example = new LoadExample(numberOfJobs); example.run(); }}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -