「java水利调度系统」科学调度水利工程
今天给各位分享java水利调度系统的知识，其中也会对科学调度水利工程进行解释，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！
本文目录一览：
java多线程高手进！！！java多线程的调度是属于内核级线程还是用户级线程？？？
java多线程的调度是属于系统内核级的调度。
Thread类的setPriority设置线程的优先级没有什么用。
你可以进行测试，很明显。
为什么使用java 任务调度系统
Timer
相信大家都已经非常熟悉 java.util.Timer 了，它是最简单的一种实现任务调度的方法，下面给出一个具体的例子：
清单 1. 使用 Timer 进行任务调度
package com.ibm.scheduler;
import java.util.Timer;
import java.util.TimerTask;
public class TimerTest extends TimerTask {
private String jobName = "";
public TimerTest(String jobName) {
super();
this.jobName = jobName;
}
@Override
public void run() {
System.out.println("execute " + jobName);
}
public static void main(String[] args) {
Timer timer = new Timer();
long delay1 = 1 * 1000;
long period1 = 1000;
// 从现在开始 1 秒钟之后，每隔 1 秒钟执行一次 job1
timer.schedule(new TimerTest("job1"), delay1, period1);
long delay2 = 2 * 1000;
long period2 = 2000;
// 从现在开始 2 秒钟之后，每隔 2 秒钟执行一次 job2
timer.schedule(new TimerTest("job2"), delay2, period2);
}
}
Output:
execute job1
execute job1
execute job2
execute job1
execute job1
execute job2
使用 Timer 实现任务调度的核心类是 Timer 和 TimerTask。其中 Timer 负责设定 TimerTask 的起始与间隔执行时间。使用者只需要创建一个 TimerTask 的继承类，实现自己的 run 方法，然后将其丢给 Timer 去执行即可。
Timer 的设计核心是一个 TaskList 和一个 TaskThread。Timer 将接收到的任务丢到自己的 TaskList 中，TaskList 按照 Task 的最初执行时间进行排序。TimerThread 在创建 Timer 时会启动成为一个守护线程。这个线程会轮询所有任务，找到一个最近要执行的任务，然后休眠，当到达最近要执行任务的开始时间点，TimerThread 被唤醒并执行该任务。之后 TimerThread 更新最近一个要执行的任务，继续休眠。
Timer 的优点在于简单易用，但由于所有任务都是由同一个线程来调度，因此所有任务都是串行执行的，同一时间只能有一个任务在执行，前一个任务的延迟或异常都将会影响到之后的任务。
回页首
ScheduledExecutor
鉴于 Timer 的上述缺陷，Java 5 推出了基于线程池设计的 ScheduledExecutor。其设计思想是，每一个被调度的任务都会由线程池中一个线程去执行，因此任务是并发执行的，相互之间不会受到干扰。需要注意的是，只有当任务的执行时间到来时，ScheduedExecutor 才会真正启动一个线程，其余时间 ScheduledExecutor 都是在轮询任务的状态。
清单 2. 使用 ScheduledExecutor 进行任务调度
package com.ibm.scheduler;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledExecutorTest implements Runnable {
private String jobName = "";
public ScheduledExecutorTest(String jobName) {
super();
this.jobName = jobName;
}
@Override
public void run() {
System.out.println("execute " + jobName);
}
public static void main(String[] args) {
ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
long initialDelay1 = 1;
long period1 = 1;
// 从现在开始1秒钟之后，每隔1秒钟执行一次job1
service.scheduleAtFixedRate(
new ScheduledExecutorTest("job1"), initialDelay1,
period1, TimeUnit.SECONDS);
long initialDelay2 = 1;
long delay2 = 1;
// 从现在开始2秒钟之后，每隔2秒钟执行一次job2
service.scheduleWithFixedDelay(
new ScheduledExecutorTest("job2"), initialDelay2,
delay2, TimeUnit.SECONDS);
}
}
Output:
execute job1
execute job1
execute job2
execute job1
execute job1
execute job2
清单 2 展示了 ScheduledExecutorService 中两种最常用的调度方法 ScheduleAtFixedRate 和 ScheduleWithFixedDelay。ScheduleAtFixedRate 每次执行时间为上一次任务开始起向后推一个时间间隔，即每次执行时间为 :initialDelay, initialDelay+period, initialDelay+2*period, …；ScheduleWithFixedDelay 每次执行时间为上一次任务结束起向后推一个时间间隔，即每次执行时间为：initialDelay, initialDelay+executeTime+delay, initialDelay+2*executeTime+2*delay。由此可见，ScheduleAtFixedRate 是基于固定时间间隔进行任务调度，ScheduleWithFixedDelay 取决于每次任务执行的时间长短，是基于不固定时间间隔进行任务调度。
回页首
用 ScheduledExecutor 和 Calendar 实现复杂任务调度
Timer 和 ScheduledExecutor 都仅能提供基于开始时间与重复间隔的任务调度，不能胜任更加复杂的调度需求。比如，设置每星期二的 16:38:10 执行任务。该功能使用 Timer 和 ScheduledExecutor 都不能直接实现，但我们可以借助 Calendar 间接实现该功能。
清单 3. 使用 ScheduledExcetuor 和 Calendar 进行任务调度
package com.ibm.scheduler;
import java.util.Calendar;
import java.util.Date;
import java.util.TimerTask;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledExceutorTest2 extends TimerTask {
private String jobName = "";
public ScheduledExceutorTest2(String jobName) {
super();
this.jobName = jobName;
}
@Override
public void run() {
System.out.println("Date = "+new Date()+", execute " + jobName);
}
/**
* 计算从当前时间currentDate开始，满足条件dayOfWeek, hourOfDay,
* minuteOfHour, secondOfMinite的最近时间
* @return
*/
public Calendar getEarliestDate(Calendar currentDate, int dayOfWeek,
int hourOfDay, int minuteOfHour, int secondOfMinite) {
//计算当前时间的WEEK_OF_YEAR,DAY_OF_WEEK, HOUR_OF_DAY, MINUTE,SECOND等各个字段值
int currentWeekOfYear = currentDate.get(Calendar.WEEK_OF_YEAR);
int currentDayOfWeek = currentDate.get(Calendar.DAY_OF_WEEK);
int currentHour = currentDate.get(Calendar.HOUR_OF_DAY);
int currentMinute = currentDate.get(Calendar.MINUTE);
int currentSecond = currentDate.get(Calendar.SECOND);
//如果输入条件中的dayOfWeek小于当前日期的dayOfWeek,则WEEK_OF_YEAR需要推迟一周
boolean weekLater = false;
if (dayOfWeek currentDayOfWeek) {
weekLater = true;
} else if (dayOfWeek == currentDayOfWeek) {
//当输入条件与当前日期的dayOfWeek相等时，如果输入条件中的
//hourOfDay小于当前日期的
//currentHour，则WEEK_OF_YEAR需要推迟一周
if (hourOfDay currentHour) {
weekLater = true;
} else if (hourOfDay == currentHour) {
//当输入条件与当前日期的dayOfWeek, hourOfDay相等时，
//如果输入条件中的minuteOfHour小于当前日期的
//currentMinute，则WEEK_OF_YEAR需要推迟一周
if (minuteOfHour currentMinute) {
weekLater = true;
} else if (minuteOfHour == currentSecond) {
//当输入条件与当前日期的dayOfWeek, hourOfDay，
//minuteOfHour相等时，如果输入条件中的
//secondOfMinite小于当前日期的currentSecond，
//则WEEK_OF_YEAR需要推迟一周
if (secondOfMinite currentSecond) {
weekLater = true;
}
}
}
}
if (weekLater) {
//设置当前日期中的WEEK_OF_YEAR为当前周推迟一周
currentDate.set(Calendar.WEEK_OF_YEAR, currentWeekOfYear + 1);
}
// 设置当前日期中的DAY_OF_WEEK,HOUR_OF_DAY,MINUTE,SECOND为输入条件中的值。
currentDate.set(Calendar.DAY_OF_WEEK, dayOfWeek);
currentDate.set(Calendar.HOUR_OF_DAY, hourOfDay);
currentDate.set(Calendar.MINUTE, minuteOfHour);
currentDate.set(Calendar.SECOND, secondOfMinite);
return currentDate;
}
public static void main(String[] args) throws Exception {
ScheduledExceutorTest2 test = new ScheduledExceutorTest2("job1");
//获取当前时间
Calendar currentDate = Calendar.getInstance();
long currentDateLong = currentDate.getTime().getTime();
System.out.println("Current Date = " + currentDate.getTime().toString());
//计算满足条件的最近一次执行时间
Calendar earliestDate = test
.getEarliestDate(currentDate, 3, 16, 38, 10);
long earliestDateLong = earliestDate.getTime().getTime();
System.out.println("Earliest Date = "
+ earliestDate.getTime().toString());
//计算从当前时间到最近一次执行时间的时间间隔
long delay = earliestDateLong - currentDateLong;
//计算执行周期为一星期
long period = 7 * 24 * 60 * 60 * 1000;
ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
//从现在开始delay毫秒之后，每隔一星期执行一次job1
service.scheduleAtFixedRate(test, delay, period,
TimeUnit.MILLISECONDS);
}
}
Output:
Current Date = Wed Feb 02 17:32:01 CST 2011
Earliest Date = Tue Feb 8 16:38:10 CST 2011
Date = Tue Feb 8 16:38:10 CST 2011, execute job1
Date = Tue Feb 15 16:38:10 CST 2011, execute job1
MDS多媒体调度系统可以为水利部门实现哪些调度功能?
通过部署MDS多媒体调度系统，水利部门调度中心的所有的软硬件设备均直接连接到水利部门的IP网络，并可通过IP网络进行信息的传输和交互，它在水利部门的调度管理方面实现了如下功能。
一、 MDS多媒体调度系统可针对McWiLL的无线覆盖实现集群对讲。MDS多媒体调度系统利用无线广播信道，实现了传统对讲系统的各种业务功能，同时使得有线电话、无线终端的通信成为有机的整体，打破了过去有线调度与无线集群独立运行的局面。
比如指挥中心人员可以用固话或手机直接呼叫应急抢险人员的无线对讲终端，及时了解抢险现场情况。而在水域沿岸部署无线基站后，工作人员可以持手持终端或单兵设备移动作业，实时和指挥中心建立语音和视频沟通，有利于指挥中心通过语音和视频第一时间了解水域沿岸的情况。
根据用户环境不同，McWiLL支持的智能终端可以有多种选择。这包括手持数字对讲终端，具备大功率喇叭、分组旋钮、紧急呼叫按钮、音量调节、单呼、对讲等多种语音调度功能，可以轻松扩展多种数据业务功能；单兵背负设备，提供视频回传、语音对讲功能，可以为指挥中心提供流域应急抢险和救援最及时最详细的现场信息；CPE设备，提供以太网接口和电话接口，适合于固定、游牧、车载移动等场景下使用，可连接视频编码器及摄像头实现无线监控；PCMCIA板卡，适合于固定、便携、移动等场景下连接网络，可以将流域水文数据实时回传指挥中心。
二、MDS多媒体调度系统可满足应急调度会议的及时召开。前期水利部门可按照部门或其他规则对工作人员分组，给每个组分配一个触发会议号码，当组内的成员需要召集组内其他人员召开一个紧急临时会议时，只需要拨打触发会议号码即可把组内所有人员召集进来参加电话会议。不但调度员可以发起应急会议，系统还允许用户通过手机和固话发起会议，用户在远程只需要拨打一个触发号码就可以召开临时会议。
通过这种手段，各级水利部门就可以利用视频会议系统频繁、简便地召开会议，同时又大大降低了会议费用、节省了人力、提高了会议的时效。
三、MDS多媒体调度系统可实现紧急情况下的应急扩音广播。比如当发生洪灾等应急事件，应急现场都比较混乱。这时调度中心可以远程控制分布在流域沿岸的扩音广播，在紧急情况发生时可以立即播放预案语音文件，第一时间对现场进行疏导和指挥，也可以人工直接呼叫远程广播，播放调度语音指令。
同时，不仅调度员可以从调度台上发起远程广播，领导在外也可以用移动手机、固定座机等发起远程广播，实现无地域限制的应急指挥。另外，调度员可以根据调度需要，选择必要区域的广播设备对其发起有针对性的广播呼叫。
四、 MDS多媒体调度系统还可实现与其他系统的对接。例如MDS多媒体调度系统可以和水文监测系统对接，实现报警联动功能。当水文监测系统出现警情发出报警信息时，调度系统可以直接启动预案，在第一时间发出调度指令，达到快速部署和指挥的目的。
同时，现场工作人员可以通过CPE设备将现场水文数据实时回传指挥中心。水文监测设备通过CPE上网能力也可以经过专门的无线网络将信息传回指挥中心。
关于java水利调度系统和科学调度水利工程的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。
发布于：2022-12-14，除非注明，否则均为原创文章，转载请注明出处。