文档章节

Java 多线程 - 线程 - 守护线程

pan_1308
 pan_1308
发布于 2017/09/05 16:10
字数 1564
阅读 10
收藏 1

一、概述

当一个应用程序里没有其他的线程运行的时候,守护线程才运行;当守护线程是程序中唯一运行的线程时,守护线程执行结束后,JVM也就结束了这个程序。

基于以上特性,守护线程通常被用来作为同一程序中普通线程(也称之为用户线程)的服务提供者。它们通常是无限循环的,以等待服务请求或者执行线程的任务。它们不能做重要的工作,因为不可能知道守护线程什么时候能够获取 cpu 时钟,并且,在没有其他线程运行的时候,守护线程随时可能结束。典型的守护线程 Java 的垃圾回收器。

注意:

1、setDaemon() 方法只能在 start() 方法被调用之前设置;一旦线程开始运行,将不能再修改守护状态;

2、isDaemon() 方法被用来检查一个线程是否是守护线程,返回 true 表示守护线程,false 表示 这个线程是 用户线程;

二、实现

示例:  创建2个线程:一个是用户线程,它将事件写入到一个队列中;另外一个是守护线程,它将管理这个队列,如果生成的事件超过 10 秒钟,该事件就会被删除。

import java.util.Date;

/**
 * 自定义事件
 */
public class MyEvent {
    public static int globalI = 0;
	public int id;
	private String name;
	private Date createTime;
	
	public MyEvent(){
		modifyI();
	}
	
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public Date getCreateTime() {
		return createTime;
	}
	public void setCreateTime(Date createTime) {
		this.createTime = createTime;
	}

	public String toString() {
		return "MyEvent [id=" + id + ", name=" + name + ", createTime="
				+ createTime + "]";
	}
	
	// 创建唯一编号的事件.
	public synchronized void modifyI(){
		id =  ++globalI;
		setId(id);
	}
}
import java.util.Date;
import java.util.Queue;
import java.util.concurrent.TimeUnit;

/**
 * 向队列中放入待处理的事件
 */
public class WriterTask implements Runnable{

	private Queue<MyEvent> queue;
	
	public WriterTask(Queue<MyEvent> queue){
		this.queue = queue;
	}
	
	public void run() {
		if(queue == null){
			System.out.println("添加操作-存放的 queue队列 未能初始化...");
		}
		for(int i=0;i<3;i++){
			MyEvent myEvent = new MyEvent();
			myEvent.setName("name_" +i);
			myEvent.setCreateTime(new Date());
			queue.add(myEvent);
			System.out.println(Thread.currentThread().getName() + "添加一个待处理事件:" + myEvent);
			try {
				TimeUnit.SECONDS.sleep(1); //休眠1s
			} catch (InterruptedException e) {
				e.printStackTrace();
			} 
			System.out.println(Thread.currentThread().getName() + ":现有 queue中的事件数为:" + queue.size());
		}
	}
}
import java.util.Date;
import java.util.Queue;
import java.util.concurrent.TimeUnit;

/***
 *  清理 queue 队列中的 待处理事件.
 */
public class CleanTesk extends Thread{

	private Queue<MyEvent> queue;
	public CleanTesk(Queue<MyEvent> queue){
		this.queue = queue;
	    setDaemon(true); // 设置为 守护线程 - 此方法是 Thread类中的
	}
	
	public void run() {
		if (queue == null) {
			System.out.println("清理操作-存放的 queue队列 未能初始化...");
		}
		while(true){
			Date date = new Date();
			clean(date);
		}
	}

	// 清理操作
	public void clean(Date date){
		boolean isDelete = false;
		if(queue.size() == 0){
			System.out.println("清理操作-存放的 queue队列 没有待处理的事件...");
			try {
				TimeUnit.SECONDS.sleep(10); //10s
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		    return;
		}
		MyEvent myEvent = queue.poll();
		if(myEvent == null){
			System.out.println("清理操作-获取待处理的事件无效...");
			return;
		}
		long difference = date.getTime() - myEvent.getCreateTime().getTime();
		if(difference >= 10000){ // 10s
		    isDelete = true;
		}else{ // 时间不够,再放回去
			queue.add(myEvent);
		}
		if(isDelete){
			System.out.println(Thread.currentThread().getName()+"-清理了 一个待处理任务...myevent:"+myEvent);
			try {
				TimeUnit.SECONDS.sleep(1); //休息1s
			} catch (InterruptedException e) {
				e.printStackTrace();
			} 
			System.out.println(Thread.currentThread().getName()+"-还剩的待处理任务...queue:"+queue.size());
		}
	}
}
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * 守护线程测试
 */
public class DaemonTest {

  public static void main(String[] args) {
	  Queue<MyEvent> queue = new LinkedBlockingQueue<MyEvent>();
	  WriterTask writerTask = new WriterTask(queue);
	  for(int i=0;i<3;i++){
		  Thread thread = new Thread(writerTask);
		  thread.start();
	  }
	
	  CleanTesk cleanTesk = new CleanTesk(queue);
	  Thread clearThread = new Thread(cleanTesk);
	  clearThread.start();
  }	
}
//console打印结果:
清理操作-存放的 queue队列 没有待处理的事件...
Thread-1添加一个待处理事件:MyEvent [id=1, name=name_0, createTime=Tue Sep 05 16:02:01 CST 2017]
Thread-0添加一个待处理事件:MyEvent [id=2, name=name_0, createTime=Tue Sep 05 16:02:01 CST 2017]
Thread-2添加一个待处理事件:MyEvent [id=3, name=name_0, createTime=Tue Sep 05 16:02:01 CST 2017]
Thread-0:现有 queue中的事件数为:3
Thread-2:现有 queue中的事件数为:3
Thread-0添加一个待处理事件:MyEvent [id=4, name=name_1, createTime=Tue Sep 05 16:02:02 CST 2017]
Thread-1:现有 queue中的事件数为:3
Thread-2添加一个待处理事件:MyEvent [id=5, name=name_1, createTime=Tue Sep 05 16:02:02 CST 2017]
Thread-1添加一个待处理事件:MyEvent [id=6, name=name_1, createTime=Tue Sep 05 16:02:02 CST 2017]
Thread-0:现有 queue中的事件数为:6
Thread-2:现有 queue中的事件数为:6
Thread-0添加一个待处理事件:MyEvent [id=7, name=name_2, createTime=Tue Sep 05 16:02:03 CST 2017]
Thread-2添加一个待处理事件:MyEvent [id=8, name=name_2, createTime=Tue Sep 05 16:02:03 CST 2017]
Thread-1:现有 queue中的事件数为:8
Thread-1添加一个待处理事件:MyEvent [id=9, name=name_2, createTime=Tue Sep 05 16:02:03 CST 2017]
Thread-0:现有 queue中的事件数为:9
Thread-1:现有 queue中的事件数为:9
Thread-2:现有 queue中的事件数为:9
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=1, name=name_0, createTime=Tue Sep 05 16:02:01 CST 2017]
Thread-4-还剩的待处理任务...queue:8
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=2, name=name_0, createTime=Tue Sep 05 16:02:01 CST 2017]
Thread-4-还剩的待处理任务...queue:7
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=3, name=name_0, createTime=Tue Sep 05 16:02:01 CST 2017]
Thread-4-还剩的待处理任务...queue:6
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=4, name=name_1, createTime=Tue Sep 05 16:02:02 CST 2017]
Thread-4-还剩的待处理任务...queue:5
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=5, name=name_1, createTime=Tue Sep 05 16:02:02 CST 2017]
Thread-4-还剩的待处理任务...queue:4
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=6, name=name_1, createTime=Tue Sep 05 16:02:02 CST 2017]
Thread-4-还剩的待处理任务...queue:3
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=7, name=name_2, createTime=Tue Sep 05 16:02:03 CST 2017]
Thread-4-还剩的待处理任务...queue:2
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=8, name=name_2, createTime=Tue Sep 05 16:02:03 CST 2017]
Thread-4-还剩的待处理任务...queue:1
Thread-4-清理了 一个待处理任务...myevent:MyEvent [id=9, name=name_2, createTime=Tue Sep 05 16:02:03 CST 2017]
Thread-4-还剩的待处理任务...queue:0
清理操作-存放的 queue队列 没有待处理的事件...

 

© 著作权归作者所有

共有 人打赏支持
pan_1308
粉丝 5
博文 95
码字总数 58819
作品 0
黄冈
私信 提问
Java 学习(27)---(多线程 / Runnable 接口 / 调度和优先级)

多线程 1 .概念 多线程:一个应用程序有多条执行路径进程:正在执行的应用程序 线程:进程的执行单元,执行路径 单线程:一个应用程序只有一条执行路径 多线程:一个应用程序有多条执行路径 ...

姜白告
08/03
0
0
Java 多线程编程总结

一、认识多任务、多进程、单线程、多线程 要认识多线程就要从操作系统的原理说起。 以前古老的DOS操作系统(V 6.22)是单任务的,还没有线程的概念,系统在每次只能做一件事情。比如你在cop...

鉴客
2010/12/16
1K
3
JAVA多线程和并发基础面试问答

多线程和并发问题是Java技术面试中面试官比较喜欢问的问题之一。在这里,从面试的角度列出了大部分重要的问题,但是你仍然应该牢固的掌握Java多线程基础知识来对应日后碰到的问题。(校对注:...

LCZ777
2014/05/26
0
0
Java多线程机制——多线程概述

本文概述 本篇文章将分四块内容对Java中的多线程机制进行介绍: 一. 多线程概述 二. 实现多线程的两种方式 三. 多线程的生命周期 四. 线程调度和控制 一. 线程与进程的概述   线程是依赖于...

Mr_Yanger
2017/11/28
0
0
java基础thread——多线程的纷争(循序渐进)

一、多线程概述 进程: 正在运行的程序,是系统进行资源分配和调用的独立单位。 每一个进程都有它自己的内存空间和系统资源。 多进程有什么意义呢? 单进程的计算机只能做一件事情,而我们现在...

潇潇漓燃
05/30
0
0

没有更多内容

加载失败,请刷新页面

加载更多

《激荡三十年》读书笔记的相关感悟3300字

《激荡三十年》读书笔记的相关感悟3300字: 《激荡三十年》是吴晓波以编年体的方式记录的中国1978年改革开放后至2008年的30年的企业史。这套被称为“新货殖列传”的“企业史记”记录了三十年...

原创小博客
13分钟前
0
0
红外接收器驱动开发

背景:使用系统的红外遥控软件没有反应,然后以为自己接线错误,反复测试,结果烧坏了一个红外接收器,信号主板没有问题。所以自己开发了一个红外接收器的python驱动。接线参见https://my.os...

mbzhong
51分钟前
2
0
ActiveMQ消息传送机制以及ACK机制详解

AcitveMQ是作为一种消息存储和分发组件,涉及到client与broker端数据交互的方方面面,它不仅要担保消息的存储安全性,还要提供额外的手段来确保消息的分发是可靠的。 一. ActiveMQ消息传送机...

watermelon11
今天
1
0
HashTable和Vector为什么逐渐被废弃

HashTable,不允许键值为null,还一个就是put方法使用sychronized方法进行线程同步,单线程无需同步,多线程可用concurren包的类型。 如编程思想里面说的作为工具类,封闭性做的不好没有一个...

noob_chr
昨天
1
0
Win10 下安装Win7双系统

很多人买了预装64位Win8/8.1的电脑后想重装(或者再安装一个)Win7系统,但是折腾半天发现以前的方法根本不奏效。这是因为预装Win8/8.1的电脑统一采用了UEFI+GPT引导模式,传统的BIOS(Legacy...

yaly
昨天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部