java两个线程互相守护

标签: java 线程 守护 | 发表时间:2015-11-28 02:04 | 作者:ontheway_lyl
出处:http://www.iteye.com

dota打累了写个小demo
最近由于工作需要,需要实现一个线程无论任何情况下都不能挂掉,就算挂掉了也必须继续运行该线程里的功能,想了一下其实也非常简单,无非就是两个线程互相守护,两个线程里实现同样的功能,线程A挂了启动线程B,线程B挂了启动线程A,好了废话不多说,直接上代码:

 

package com.thread.daemon.test;

import java.util.ArrayList;
import java.util.List;


/**
 * 两个线程互相守护,线程A挂了启动线程B,线程B挂了启动线程A
 * @author liangjian
 */
public class ThreadDaemonTest {

	static List<String> list = new ArrayList<>();
	static Thread threadA ;
	static Thread threadB ;
	
	public static void threadDaemonA(){
		threadA = new Thread(new Runnable() {
			boolean flag = true;
			int count = 0;
			@Override
			public void run() {
				threadA.setName("threadDaemonA ");
				while(flag){
					try {
						threadA.sleep(1000);
					} catch (InterruptedException e1) {
						e1.printStackTrace();
						flag = false;
						Thread.currentThread().interrupt();
						threadA = null;
						threadDaemonB();
					}finally{
					}
					count++;
					System.out.println(threadA.getName()+count+ " <--> threadB = "+threadB);
					if(count == 10){
						System.err.println(count);
						try {
							String temp = list.get(0);
						} catch (Exception e) {
							e.printStackTrace();
							threadDaemonB();
							flag = false;
							Thread.currentThread().interrupt();
							threadA = null;
							return;
						}finally{
						}
					}
				}
			}
		});
		threadA.start();
	}
	public static void threadDaemonB(){
		threadB = new Thread(new Runnable() {
			boolean flag = true;
			int count = 0;
			@Override
			public void run() {
				threadB.setName("threadDaemonB ");
				while(flag){
					try {
						threadB.sleep(1000);
					} catch (InterruptedException e1) {
						e1.printStackTrace();
						flag = false;
						Thread.currentThread().interrupt();
						threadB = null;
						threadDaemonA();
					}
					count++;
					System.out.println(threadB.getName()+count+" <--> threadA = "+threadA);
					if(count == 10){
						
						try {
							String temp = list.get(0);
							return ;
						} catch (Exception e) {
							e.printStackTrace();
							flag = false;
							threadB = null;
							Thread.currentThread().interrupt();
							threadDaemonA();
						}finally{
						}
					}
				}
			}
		});
		threadB.start();
	}
	
	public static void main(String[] args) {
		threadDaemonA();
	}

}

 





已有 0 人发表留言,猛击->> 这里<<-参与讨论


ITeye推荐



相关 [java 线程 守护] 推荐:

java两个线程互相守护

- - Java - 编程语言 - ITeye博客
dota打累了写个小demo. 最近由于工作需要,需要实现一个线程无论任何情况下都不能挂掉,就算挂掉了也必须继续运行该线程里的功能,想了一下其实也非常简单,无非就是两个线程互相守护,两个线程里实现同样的功能,线程A挂了启动线程B,线程B挂了启动线程A,好了废话不多说,直接上代码:. package com.thread.daemon.test; import java.util.ArrayList; import java.util.List; /** * 两个线程互相守护,线程A挂了启动线程B,线程B挂了启动线程A * @author liangjian */ public class ThreadDaemonTest {.

Java线程池

- - 企业架构 - ITeye博客
线程的使用在java中占有极其重要的地位,在jdk1.4极其之前的jdk版本中,关于线程池的使用是极其简陋的. 在jdk1.5之后这一情况有了很大的改观. Jdk1.5之后加入了java.util.concurrent包,这个包中主要介绍java中线程以及线程池的使用. 为我们在开发中处理线程的问题提供了非常大的帮助.

Java 线程池

- - 编程语言 - ITeye博客
在项目中,系统启动一个新线程的成本是比较高的,因为它涉及与操作系统交互. 在这种情形下,使用线程池可以很好地提高性能,尤其是当程序中需要创建大量生存周期很短的线程时,更应该考虑使用线程池. 使用线程池可以有效地控制系统中并发线程的数量,当系统中包含大量并发线程时,会导致系统性能剧烈下降,甚至导致JVM崩溃,而线程池的最大线程数参数可以控制系统中并发线程数不超过此数.

Java Thread多线程

- - CSDN博客推荐文章
Java Thread多线程. Java 多线程例子1 小例子. super("zhuyong");//设置线程的名字,默认为“TestThread”. Java 多线程例子2 前台线程(用户线程) 后台线程(守护线程 ). 1,setDaemon(true)后就是后台线程(守护线程 ),反之就是前台线程(用户线程).

Java线程之FutureTask

- - zzm
FutureTask是Future和Callable的结合体. 然后通过Future来取得计算结果. 但是,若开启了多个任务,我们无从知晓哪个任务最先结束,因此,若要实现“当某任务结束时,立刻做一些事情,例如记录日志”这一功能,就需要写一些额外的代码. FutureTask正是为此而存在,他有一个回调函数protected void done(),当任务结束时,该回调函数会被触发.

[Java] Java 多线程案例分析

- - V2EX
现要从 hbase中导出 2016 年整年的,大约 10w只股票行情数据,数据总量约 100t. 汇总到 hdfs中供需求方使用. 已知数据量规模大概是 100t,那么单台机器处理肯定不是不行的,先不说大多数磁盘都没这么大,即便磁盘有这么大,单台机器处理对于内存和 cpu 要求也很高,所以我们将问题一般化,使用数量有限的低配机器.

Java多线程之synchronized

- - CSDN博客推荐文章
这里通过三个测试类阐述了synchronized应用的不同场景. 首先是最基本的synchronized Method的使用.  * @see 概述:Java中的每个对象都有一个锁(lock)或者叫做监视器(monitor) .  * @see 说明:当synchronized关键字修饰一个方法时,则该方法为同步方法 .

java线程池分析

- - BlogJava-首页技术区
    在Java 5.0之前启动一个任务是通过调用Thread类的start()方法来实现的,任务的提于交和执行是同时进行的,如果你想对任务的执行进行调度或是控制 同时执行的线程数量就需要额外编写代码来完成. 5.0里提供了一个新的任务执行架构使你可以轻松地调度和控制任务的执行,并且可以建立一个类似数据库连接 池的线程池来执行任务.

java线程取消方式

- - 编程语言 - ITeye博客
JAVA任务取消方式一般有2种. 第一种设置某个取消标志,任务定期查看该标志,这种方式存在任务取消并不能保证任务立即取消,更糟糕的是有可能任务永远不会结束. 第二种是利用的中断机制,JVM并不能保证阻塞方法检测到中断的速度,但是实际中还是非常快的. 实例一(使用取消标志,会发现取消的任务还执行中,只有执行完再次检测标志任务才取消).

Java线程池应用

- - CSDN博客架构设计推荐文章
1.减少了创建和销毁线程的次数,每个工作线程都可以被重复利用,可执行多个任务. 2.可以根据系统的承受能力,调整线程池中工作线线程的数目,防止因为消耗过多的内存,而把服务器累趴下(每个线程需要大约1MB内存,线程开的越多,消耗的内存也就越大,最后死机). Java里面线程池的顶级接口是Executor,但是严格意义上讲Executor并不是一个线程池,而只是一个执行线程的工具.