java任務框架
❶ java 任務調度 框架比較多 那個 最好用呢 .. quartz 嗎。誰能給我推薦一下呢。
基本上是Quartz。我見過所有的項目都是用的Quartz
Quartz支持Cron表達式定義時間點也支持SimpleTrigger對應時間點,可以很精確的定義時間點。
Quartz支持集群,可以在多個伺服器(連同一個資料庫)自動分配到不同的伺服器上執行。
Quartz支持多種錯誤處理形式(如錯誤後下次不執行、馬上重新執行、下次繼續執行等)
Quartz支持多種漏觸發處理(如關機漏觸發情況)
Quartz還有很多優點,同類框架基本和他沒有可比性
❷ java並發框架有哪些
Java並發框架java.util.concurrent是JDK5中引入到標准庫中的(採用的是Doug
Lea的並發庫)。該包下的類可以分為這么塊:
Executors
1)介面:
Executor(例子涉及):用來執行提交的Runnable任務的對象。是一個簡單的標准化介面,用來定義包括線程池、非同步IO、輕量級任務框架等等。任務可以由一個新創建的線程、一個已有任務執行線程、或是線程直接調用execute()來執行,可以串列也可並行執行,取決於使用的是哪個Executor具體類。
ExecutorService(例子涉及):Executor的子介面,提供了一個更加具體的非同步任務執行框架:提供了管理結束的方法,以及能夠產生Future以跟蹤非同步任務進程的方法。一個ExcutorService管理著任務隊列和任務調度。
ScheledExecutorService(例子涉及):ExecutorService的子介面,增加了對延遲和定期任務執行的支持。
Callable(例子涉及):一個返回結果或拋出異常的任務,實現類需要實現其中一個沒有參數的叫做call的方法。Callabe類似於Runnable,但是Runnable不返回結果且不能拋出checked
exception。ExecutorService提供了安排Callable非同步執行的方法。
Future(例子涉及):代表一個非同步計算的結果(由於是並發執行,結果可以在一段時間後才計算完成,其名字可能也就是代表這個意思吧),提供了可判斷執行是否完成以及取消執行的方法。
2)實現:
ThreadPoolExecutor和ScheledThreadPoolExecutor:可配置線程池(後者具備延遲或定期調度功能)。
Executors(例子涉及):提供Executor、ExecutorService、ScheledExecutorService、ThreadFactory以及Callable的工廠方法及工具方法。
FutureTask:對Future的實現
ExecutorCompletionService(例子涉及):幫助協調若干(成組)非同步任務的處理。
Queues
非阻塞隊列:ConcurrentLinkedQueue類提供了一個高效可伸縮線程安全非阻塞FIFO隊列。
阻塞隊列:BlockingQueue介面,有五個實現類:LinkedBlockingQueue(例子涉及)、ArrayBlockingQueue、SynchronousQueue、PriorityBlockingQueue和DelayQueue。他們對應了不同的應用環境:生產者/消費者、消息發送、並發任務、以及相關並發設計。
Timing
TimeUnit類(例子涉及):提供了多種時間粒度(包括納秒)用以表述和控制基於超時的操作。
Synchronizers 提供特定用途同步語境
Semaphore(例子涉及):計數信號量,這是一種經典的並發工具。
CountDownLatch(例子涉及):簡單的倒計數同步工具,可以讓一個或多個線程等待直到另外一些線程中的一組操作處理完成。
CyclicBarrier(例子涉及):可重置的多路同步工具,可重復使用(CountDownLatch是不能重復使用的)。
Exchanger:允許兩個線程在匯合點交換對象,在一些pipeline設計中非常有用。
Concurrent Collections
除隊列外,該包還提供了一些為多線程上下文設計的集合實現:ConcurrentHashMap、CopyOnWriteArrayList及CopyOnWriteArraySet。
注意:"Concurrent"前綴的類有別於"synchronized"前綴的類。「concurrent」集合是線程安全的,不需要由單排斥鎖控制的(無鎖的)。以ConcurrentHashMap為例,允許任何數量的並發讀及可調數量的並發寫。「Synchronized」類則一般通過一個單鎖來防止對集合的所有訪問,開銷大且伸縮性差。
❸ 現在有什麼好用的java開發框架
分享10個最好的工具、框架和庫,以幫助 Java 開發人員在不同的 Java 項目中更好地執行單元測試和集成測試。
▌JUnit
JUnit 應該不需要過多介紹。哪怕你是一位 Java 初學者,我想你也應該聽說過它,它能夠讓你為 Java 代碼編寫單元測試。
幾乎所有常用的 IDE,比如 Eclipse、NetBeans 和 IntelliJ,都能夠集成 JUnit,這意味著開發者直接可以在這些 IDE 中編寫並運行單元測試。
目前大多數人仍然在使用 JUnit 4,事實上新的 JUnit 5 已經發布。你可以用 JUnit 進行單元測試和集成測試,此外,它還支持 Java 8 功能。
❹ java的幾種定時任務
java定時任務有三種:
- JDK自帶 :JDK自帶的Timer以及JDK1.5+ 新增的ScheledExecutorService;
- Quartz :簡單卻強大的JAVA作業調度框架
- Spring3.0以後自帶的task :可以將它看成一個輕量級的Quartz,而且使用起來比Quartz簡單許多;
代碼參考:
JDK 自帶的定時器實現
schele(TimerTask task, Date time) 特定時間執行
public static void main(String[] args) {
for (int i = 0; i < 10; ++i) {
new Timer("timer - " + i).schele(new TimerTask() {
@Override
public void run() {
println(Thread.currentThread().getName() + " run ");
}
}, new Date(System.currentTimeMillis() + 2000));
}
}Quartz 定時器實現
2.1 通過maven引入依賴(這里主要介紹2.3.0) 注意:shiro-scheler中依賴的是1.x版本 如果同時使用會沖突
<!-- https://mvnrepository.com/artifact/org.quartz-scheler/quartz -->
<dependency>
<groupId>org.quartz-scheler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.0</version>
</dependency>2.2創建Job類
public class TestJob implements Job{
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
println(Thread.currentThread().getName() + " test job begin " + DateUtil.getCurrentTimeStr());
}
}2.3調度任務
public static void main(String[] args) throws InterruptedException, SchelerException {
Scheler scheler = new StdSchelerFactory().getScheler();
// 開始
scheler.start();
// job 唯一標識 test.test-1
JobKey jobKey = new JobKey("test" , "test-1");
JobDetail jobDetail = JobBuilder.newJob(TestJob.class).withIdentity(jobKey).build();
Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("test" , "test")
// 延遲一秒執行
.startAt(new Date(System.currentTimeMillis() + 1000))
// 每隔一秒執行 並一直重復
.withSchele(SimpleScheleBuilder.simpleSchele().withIntervalInSeconds(1).repeatForever())
.build();
scheler.scheleJob(jobDetail , trigger);
Thread.sleep(5000);
// 刪除job
scheler.deleteJob(jobKey);
}
3.Spring 相關的任務調度
3.1 配置文件實現
spring-schele.xml
<task:scheler id="myScheler" pool-size="10" />
<task:scheled-tasks scheler="myScheler">
<task:scheled ref="job" method="test" cron="0 * * * * ?"/>
</task:scheled-tasks>
3.2註解實現
spring-schele.xml
<task:scheler id="myScheler" pool-size="10" />
// 啟用註解
<task:annotation-driven scheler="myScheler"/>
@Component
public class Task{
@Scheled(cron="0/5 * * * * ? ") //每5秒執行一次
public void execute(){
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println(sdf.format(DateTime.now().toDate())+"*********B任務每5秒執行一次進入測試");
}
}