Java有一種特殊線程,守護線程,這種線程優先級特別低,只有在同一程序中的其他線程不執行時才會執行。
由于守護線程擁有這些特性,所以,一般用為為程序中的普通線程(也稱為用戶線程)提供服務。它們一般會有一個無限循環,或用于等待請求服務,或用于執行任務等。它們不可以做任何重要的工作,因為我們不確定他們什么時才能分配到CPU運行時間,而且當沒有其他線程執行時,它們就會自動終止。這類線程的一個典型應用就是Java的垃圾回收。
在本節示例中,我們將創建兩個線程,一個是普通線程,向隊列中寫入事件;另外一個是守護線程,清除隊列中的事件,刪除存在時間超過10秒的事件。
知其然
按照如下步驟,實現示例程序。
1.創建Event類,該類僅僅用于保存程序執行所需的事件信息。聲明兩個屬性,一個是java.util.Date類型的的date熟悉,另外一個是String類型的event屬性;然后生成這兩個屬性的讀寫方法。代碼如下:
public class Event {
private Date date;
private String event;
public Date getDate() {
return date;
}
public void setDate(Date date) {
this.date = date;
}
public String getEvent() {
return event;
}
public void setEvent(String event) {
this.event = event;
}
}
2.創建一個名為WriterTask的類,并且實現Runnable接口。代碼如下:
public class WriterTask implements Runnable {
3.聲明一個用來存儲事件的隊列屬性,實現類的構造函數,并且利用其參數來初始化隊列屬性。代碼如下:
private Deque<Event> deque;
public WriterTask(Deque<Event> deque) {
this.deque = deque;
}
4.實現該任務的run()方法,方法中含有一個遍歷100次的循環。在每次遍歷中,創建一個新的Event對象,然后保存到隊列中,再睡眠1秒鐘。代碼如下:
@Override
public void run() {
for (int i = 0; i < 100; i++) {
Event event = new Event();
event.setDate(new Date());
event.setEvent(String.format("The thread %s has generated an event",
Thread.currentThread().getId()));
deque.addFirst(event);
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
5.創建一個名為CleanerTask的類,并繼承Thread類。代碼如下:
public class CleanerTask extends Thread {
6.聲明一個用來存儲事件的隊列屬性,實現類的構造函數,并且利用其參數來初始化隊列屬性。在構造方法中,通過調用setDaemon()方法,將該線程設置為守護線程。代碼如下:
private Deque<Event> deque;
public CleanerTask(Deque<Event> deque) {
this.deque = deque;
setDaemon(true);
}
7.實現run()方法,方法體內有一個無限循環,用于獲取當前時間,然后調用clearn()方法。代碼如下:
@Override
public void run() {
while (true) {
Date date = new Date();
clean(date);
}
}
8.實現clean()方法,在該方法內,獲取最后面的一個時間,然后檢查時間時間和當前時間的時間差,如果在10秒鐘之前創建的,則刪除當前事件,再檢查下一個事件。如果有事件被刪除,則顯示打印出被刪除事件的信息,然后還將打印出隊列的最新長度,這樣就可以觀察到程序的執行進展。代碼如下:
private void clean(Date date) {
long difference;
boolean delete;
if (deque.size() == 0) {
return;
}
delete = false;
do {
Event e = deque.getLast();
difference = date.getTime() - e.getDate().getTime();
if (difference > 10000) {
System.out.printf("Cleaner: %s\n", e.getDate());
deque.removeLast();
delete = true;
}
} while (difference > 10000);
if (delete) {
System.out.printf("Clearner: Size of the queue: %d\n", deque.size());
}
}
9.創建程序的主類,Main類,然后實現main()方法。代碼如下:
public class Main {
public static void main(String[] args) {
10.使用Deque類創建存儲事件的隊列。代碼如下:
Deque<Event> deque = new ArrayDeque<>();
11.創建并啟動三個WriterTask線程和一個CleanerTask線程。代碼如下:
Deque<Event> deque = new ArrayDeque<>();
WriterTask writer = new WriterTask(deque);
for (int i = 0; i < 3; i++) {
Thread thread = new Thread(writer);
thread.start();
}
CleanerTask cleaner = new CleanerTask(deque);
cleaner.start();
12.執行程序,查看執行結果。
知其所以然
分析程序的執行結果就可以看出,隊列先增加到30,然后就在27到30之間變化,知道程序執行結束。
程序首先從三個WriterTask線程開始執行,每個線程先隊列增加一個事件,然后睡眠1秒鐘。在前10秒過后,在隊列中將存在三十個事件。在這10秒期間,當三個WriterTask線程都睡眠時,CleanerTask線程也會運行,但是不會刪除任何事件,因為所有的事件的生成時間還不超過10秒。在前10秒過后的時間里,每秒鐘三個WriterTask向隊列中添加三個事件;同樣,CleanerTask每秒會刪除三個事件。所以,事件的數目在27到30之間徘徊。
當WriterTask線程都休眠時,我們就可以自由處理時間,這段時間讓守護線程得以運行。如果將WriterTask線程的睡眠時間設置得更短一點,那么CleanerTask線程將獲取更少的CPU運行時間。果真如此的話,因為CleanerTask線程一直得不到足夠的運行時間不能用于刪除足夠的事件,隊列的長度將會一直增長下去。
永無止境
僅能在調用start()方法之前,通過調用setDaemon()方法將線程設置為守護線程。一旦線程開始運行,則不能修改守護狀態。
還可以使用isDaemon()來檢查一個線程是否為守護線程。如果是守護線程,則返回true;如果是普通線程,則返回false。
拿來主義
本文是從 《Java 7 Concurrency Cookbook》 (D瓜哥竊譯為 《Java7并發示例集》 )翻譯而來,僅作為學習資料使用。沒有授權,不得用于任何商業行為。
小有所成
本節所用的所有示例代碼的完整版。
Event類的完整代碼
package com.diguage.books.concurrencycookbook.chapter1.recipe7;
import java.util.Date;
/**
* 事件信息類
* Date: 2013-09-19
* Time: 22:56
*/
public class Event {
private Date date;
private String event;
public Date getDate() {
return date;
}
public void setDate(Date date) {
this.date = date;
}
public String getEvent() {
return event;
}
public void setEvent(String event) {
this.event = event;
}
}
WriterTask類的完整代碼
package com.diguage.books.concurrencycookbook.chapter1.recipe7;
import java.util.Date;
import java.util.Deque;
import java.util.concurrent.TimeUnit;
/**
* 每秒生成一個事件。
* Date: 2013-09-19
* Time: 22:59
*/
public class WriterTask implements Runnable {
private Deque<Event> deque;
public WriterTask(Deque<Event> deque) {
this.deque = deque;
}
@Override
public void run() {
for (int i = 0; i < 100; i++) {
Event event = new Event();
event.setDate(new Date());
event.setEvent(String.format("The thread %s has generated an event",
Thread.currentThread().getId()));
deque.addFirst(event);
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
CleanerTask類的完整代碼
package com.diguage.books.concurrencycookbook.chapter1.recipe7;
import java.util.Date;
import java.util.Deque;
/**
* 事件清理
* Date: 2013-09-19
* Time: 23:33
*/
public class CleanerTask extends Thread {
private Deque<Event> deque;
public CleanerTask(Deque<Event> deque) {
this.deque = deque;
setDaemon(true);
}
@Override
public void run() {
while (true) {
Date date = new Date();
clean(date);
}
}
/**
* 刪除事件。
*
* @param date
*/
private void clean(Date date) {
long difference;
boolean delete;
if (deque.size() == 0) {
return;
}
delete = false;
do {
Event e = deque.getLast();
difference = date.getTime() - e.getDate().getTime();
if (difference > 10000) {
System.out.printf("Cleaner: %s\n", e.getDate());
deque.removeLast();
delete = true;
}
} while (difference > 10000);
if (delete) {
System.out.printf("Clearner: Size of the queue: %d\n", deque.size());
}
}
}
Main類的完整代碼
package com.diguage.books.concurrencycookbook.chapter1.recipe7;
import java.util.ArrayDeque;
import java.util.Deque;
/**
* Date: 2013-09-19
* Time: 23:54
*/
public class Main {
public static void main(String[] args) {
Deque<Event> deque = new ArrayDeque<>();
WriterTask writer = new WriterTask(deque);
for (int i = 0; i < 3; i++) {
Thread thread = new Thread(writer);
thread.start();
}
CleanerTask cleaner = new CleanerTask(deque);
cleaner.start();
}
}