国产成人啪精品午夜在线播放 ,一级国产片,色人阁七月

實(shí)現(xiàn)功能：實(shí)時監(jiān)控指定目錄下文件的增加 / 更新 / 刪除情況.

Java代碼

// monitor.file.FileMonitor.java
package monitor.file;
/**
*@date 2010-3-18 上午10:12:14
*@author dycc
*@file monitor.file.FileMonitor.java
*/
public class FileMonitor {
public static void main(String[] args) {
FileSchedulerTask task = new FileSchedulerTask("D:\\Temp");
FileScheduler monitor = new FileScheduler();
monitor.schedule(task, new TimeStep());
}
}
// monitor.file.FileScheduler.java
package monitor.file;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
/**
*@date 2010-3-18 上午10:31:26
*@author dycc
*@file monitor.file.FileScheduler.java
*/
public class FileScheduler {
// 定時器
private final Timer timer;
public FileScheduler(){
timer = new Timer();
}
public FileScheduler(boolean isDaemon){
// 是否為守護(hù)線程
timer = new Timer(isDaemon);
}
/**
* 為定時器分配可執(zhí)行任務(wù)
* @param task
* @param step
*/
public void schedule(Runnable task,TimeStep step){
Date time = step.next();
SchedulerTimerTask timeTask = new SchedulerTimerTask(task,step);
// 安排在指定的時間 time 執(zhí)行指定的任務(wù) timetask
timer.schedule(timeTask, time);
// 此處不使用
// public void schedule(TimerTask task, Date firstTime, long period)
// 執(zhí)行定時任務(wù),而是使用 reSchedule 來重復(fù)執(zhí)行任務(wù),是因?yàn)槭状螆?zhí)行時可能需要做一些額外的初始化,
// 這樣方便以后擴(kuò)展.
}
/**
* 重新執(zhí)行任務(wù)
* @param task
* @param step
*/
private void reSchedule(Runnable task,TimeStep step){
Date time = step.next();
SchedulerTimerTask timeTask = new SchedulerTimerTask(task,step);
// 安排在指定的時間 time 執(zhí)行指定的任務(wù) timetask
timer.schedule(timeTask, time);
}
/**
* 停止當(dāng)前定時器
*/
public void cancle(){
timer.cancel();
}
/**
* 定時任務(wù)
* @author dycc
*
*/
private class SchedulerTimerTask extends TimerTask{
private Runnable task;
private TimeStep step;
public SchedulerTimerTask(Runnable task,TimeStep step){
this.task = task;
this.step = step;
}
@Override
public void run() {
// 執(zhí)行指定任務(wù)
task.run();
// 繼續(xù)重復(fù)執(zhí)行任務(wù)
reSchedule(task, step);
}
}
}
// monitor.file.FileSchedulerTask.java
package monitor.file;
import java.io.File;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
/**
*@date 2010-3-18 上午10:39:29
*@author dycc
*@file monitor.file.FileSchedulerTask.java
*/
public class FileSchedulerTask implements Runnable{
private boolean firstRun = true;
private String directory = "";
// 初始文件信息
private Map<String,Long> currentFiles = new HashMap<String,Long>();
// 當(dāng)前文件信息
private Set<String> newFiles = new HashSet<String>();
/**
* 構(gòu)造函數(shù)
*/
public FileSchedulerTask(){
}
public FileSchedulerTask(String directory){
this.directory = directory;
}
/**
* 在 run() 中執(zhí)行具體任務(wù)
*/
public void run() {
File file = new File(directory);
if(firstRun){
firstRun = false;
// 初次運(yùn)行
loadFileInfo(file);
System.out.println("----- init success -----");
} else{
// 檢查文件更新狀態(tài)[add,update]
checkFileUpdate(file);
// 檢查被移除的文件[remove]
checkRemovedFiles();
// 清空臨時文件集合
newFiles.clear();
}
}
/**
* 初始化文件信息
* @param file
*/
private void loadFileInfo(File file){
if(file.isFile()){
currentFiles.put(file.getAbsolutePath(), file.lastModified());
return;
}
File[] files = file.listFiles();
for(int i=0;i<files.length;i++){
loadFileInfo(files[i]);
}
}
/**
* 檢查文件更新狀態(tài)
* @param file
*/
private void checkFileUpdate(File file){
if(file.isFile()){
// 將當(dāng)前文件加入到 newFiles 集合中
newFiles.add(file.getAbsolutePath());
//
Long lastModified = currentFiles.get(file.getAbsolutePath());
if(lastModified == null){
// 新加入文件
currentFiles.put(file.getAbsolutePath(), file.lastModified());
System.out.println("添加文件:" + file.getAbsolutePath());
return;
}
if(lastModified.doubleValue() != file.lastModified()){
// 更新文件
currentFiles.put(file.getAbsolutePath(), file.lastModified());
System.out.println("更新文件:" + file.getAbsolutePath());
return;
}
return;
} else if(file.isDirectory()){
File[] files = file.listFiles();
if(files == null || files.length == 0){
// 沒有子文件或子目錄時返回
return;
}
for(int i=0;i<files.length;i++){
checkFileUpdate(files[i]);
}
}
}
/**
* 檢查被移除的文件
*/
private void checkRemovedFiles(){
// 增加或更新時,newFiles.size() == currentFiles.size()
// 刪除時, newFiles.size() < currentFiles.size()
// 不可能出現(xiàn) newFiles.size() > currentFiles.size()
if(newFiles.size() == currentFiles.size()){
// 增加或更新時沒有被移除的文件,直接返回
return;
}
Iterator<String> it = currentFiles.keySet().iterator();
while(it.hasNext()){
String filename = it.next();
if(!newFiles.contains(filename)){
// 此處不能使用 currentFiles.remove(filename);從 map 中移除元素,
// 否則會引發(fā)同步問題.
// 正確的做法是使用 it.remove();來安全地移除元素.
it.remove();
System.out.println("刪除文件:" + filename);
}
}
}
/**
* 起始目錄
* @return
*/
public String getDirectory() {
return directory;
}
public void setDirectory(String directory) {
this.directory = directory;
}
}
// monitor.file.TimeStep.java
package monitor.file;
import java.util.Calendar;
import java.util.Date;
/**
*@date 2010-3-18 上午10:12:14
*@author dycc
*@file monitor.file.TimeStep.java
*/
public class TimeStep {
private Calendar calendar = Calendar.getInstance();
// calendar field
private int field = Calendar.SECOND;
// the amount of the date or time
private int amount = 10;
/**
* field
* @return
*/
public int getField() {
return field;
}
public void setField(int field) {
this.field = field;
}
/**
* amount
* @return
*/
public int getAmount() {
return amount;
}
public void setAmount(int amount) {
this.amount = amount;
}
/**
* 獲取時間
* @exception IllegalArgumentException if field is unknown
* @return
*/
public Date next(){
calendar.add(field, amount);
return calendar.getTime();
}
}

本站僅提供存儲服務(wù)，所有內(nèi)容均由用戶發(fā)布，如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請點(diǎn)擊舉報(bào)。

免费视频淫片aa毛片_日韩高清在线亚洲专区vr_日韩大片免费观看视频播放_亚洲欧美国产精品完整版