java的多线程之四(线程的操作)

本文来自:高爽|Coder,原文地址:http://blog.csdn.net/ghsau/article/details/17560467,转载请注明。

线程中断

线程中断涉及到三个方法,如下:

interrupt()方法用于中断线程,通常的理解来看,只要某个线程启动后,调用了该方法,则该线程不能继续执行了,来看个小例子:

 

 1 public class InterruptTest {
 2     public static void main(String[] args) throws InterruptedException {
 3         MyThread t = new MyThread("MyThread");
 4         t.start();
 5         Thread.sleep(100);// 睡眠100毫秒
 6         t.interrupt();// 中断t线程
 7     }
 8 }
 9 class MyThread extends Thread {
10     int i = 0;
11     public MyThread(String name) {
12         super(name);
13     }
14     public void run() {
15         while(true) {// 死循环,等待被中断
16             System.out.println(getName() + getId() + "执行了" + ++i + "次");
17         }
18     }
19 }

运行后,我们发现,线程t一直在执行,没有被中断,原来interrupt()是骗人的,汗!其实interrupt()方法并不是中断线程的执行,而是为调用该方法的线程对象打上一个标记,设置其中断状态为true,通过isInterrupted()方法可以得到这个线程状态,我们将上面的程序做一个小改动:

 

 1 public class InterruptTest {
 2     public static void main(String[] args) throws InterruptedException {
 3         MyThread t = new MyThread("MyThread");
 4         t.start();
 5         Thread.sleep(100);// 睡眠100毫秒
 6         t.interrupt();// 中断t线程
 7     }
 8 }
 9 class MyThread extends Thread {
10     int i = 0;
11     public MyThread(String name) {
12         super(name);
13     }
14     public void run() {
15         while(!isInterrupted()) {// 当前线程没有被中断,则执行
16             System.out.println(getName() + getId() + "执行了" + ++i + "次");
17         }
18     }
19 }

这样的话,线程被顺利的中断执行了。很多人实现一个线程类时,都会再加一个flag标记,以便控制线程停止执行,其实完全没必要,通过线程自身的中断状态,就可以完美实现该功能。如果线程在调用 Object 类的 wait()、wait(long) 或 wait(long, int) 方法,或者该类的 join()、join(long)、join(long, int)、sleep(long) 或 sleep(long, int) 方法过程中受阻,则其中断状态将被清除,它还将收到一个 InterruptedException。 我们可以捕获该异常,并且做一些处理。另外,Thread.interrupted()方法是一个静态方法,它是判断当前线程的中断状态,需要注意的是,线程的中断状态会由该方法清除。换句话说,如果连续两次调用该方法,则第二次调用将返回 false(在第一次调用已清除了其中断状态之后,且第二次调用检验完中断状态前,当前线程再次中断的情况除外)。

线程让步

线程让步用于正在执行的线程,在某些情况下让出CPU资源,让给其它线程执行,来看一个小例子:

 

 1 public class YieldTest {
 2     public static void main(String[] args) throws InterruptedException {
 3         // 创建线程对象
 4         YieldThread t1 = new YieldThread("t1");
 5         YieldThread t2 = new YieldThread("t2");
 6         // 启动线程
 7         t1.start();
 8         t2.start();
 9         // 主线程休眠100毫秒
10         Thread.sleep(100);
11         // 终止线程
12         t1.interrupt();
13         t2.interrupt();
14     }
15 }
16 class YieldThread extends Thread {
17     int i = 0;
18     public YieldThread(String name) {
19         super(name);
20     }
21     public void run() {
22         while(!isInterrupted()) {
23             System.out.println(getName() + "执行了" + ++i + "次");
24             if(i % 10 == 0) {// 当i能对10整除时,则让步
25                 Thread.yield();
26             }
27         }
28     }
29 }

输出结果略,从输出结果可以看到,当某个线程(t1或者t2)执行到10次、20次、30次等时,就会马上切换到另一个线程执行,接下来再交替执行,如此往复。注意,如果存在synchronized线程同步的话,线程让步不会释放锁(监视器对象)

线程睡眠

线程睡眠的过程中,如果是在synchronized线程同步内,是持有锁(监视器对象)的,也就是说,线程是关门睡觉的,别的线程进不来,来看一个小例子:

 

 1 public class SleepTest {
 2     public static void main(String[] args) {
 3         // 创建共享对象
 4         Service service = new Service();
 5         // 创建线程
 6         SleepThread t1 = new SleepThread("t1", service);
 7         SleepThread t2 = new SleepThread("t2", service);
 8         // 启动线程
 9         t1.start();
10         t2.start();
11     }
12
13 }
14 class SleepThread extends Thread {
15     private Service service;
16     public SleepThread(String name, Service service) {
17         super(name);
18         this.service = service;
19     }
20     public void run() {
21         service.calc();
22     }
23 }
24 class Service {
25     public synchronized void calc() {
26         System.out.println(Thread.currentThread().getName() + "准备计算");
27         System.out.println(Thread.currentThread().getName() + "感觉累了,开始睡觉");
28         try {
29             Thread.sleep(10000);// 睡10秒
30         } catch (InterruptedException e) {
31             return;
32         }
33         System.out.println(Thread.currentThread().getName() + "睡醒了,开始计算");
34         System.out.println(Thread.currentThread().getName() + "计算完成");
35     }
36 }

线程合并

线程合并是优先执行调用该方法的线程,再执行当前线程,来看一个小例子:

 

 1 public class JoinTest {
 2     public static void main(String[] args) throws InterruptedException {
 3         JoinThread t1 = new JoinThread("t1");
 4         JoinThread t2 = new JoinThread("t2");
 5         t1.start();
 6         t2.start();
 7         t1.join();
 8         t2.join();
 9         System.out.println("主线程开始执行!");
10     }
11 }
12 class JoinThread extends Thread {
13     public JoinThread(String name) {
14         super(name);
15     }
16     public void run() {
17         for(int i = 1; i <= 10; i++)
18             System.out.println(getName() + getId() + "执行了" + i + "次");
19     }
20 }

t1和t2都执行完才继续主线程的执行,所谓合并,就是等待其它线程执行完,再执行当前线程,执行起来的效果就好像把其它线程合并到当前线程执行一样

线程优先级

线程最低优先级为1,最高优先级为10,看起来就有10个级别,但这10个级别能不能和CPU对应上,还未可知,Thread类中提供了优先级的三个常量,如下:

java.lang.Thread
public static final int MAX_PRIORITY 10
public static final int MIN_PRIORITY 1
public static final int NORM_PRIORITY 5

我们创建线程对象后,如果不显示的设置优先级的话,默认为5。优先级可以看成一种特权,优先级高的,获取CPU调度的机会就大,优先级低的,获取CPU调度的机会就小,这个和我们现实生活很一样啊,优胜劣汰。线程优先级的示例就不写了,比较简单。

wait()和sleep()区别

区别太大了,但是在Java线程面试题中是很常见的问题,相信你阅读过本专栏后,能够轻松的解答,这里不再赘述。

时间: 2024-10-11 06:03:51

java的多线程之四(线程的操作)的相关文章

java核心-多线程(4)-线程类基础知识

1.并发 <1>使用并发的一个重要原因是提高执行效率.由于I/O等情况阻塞,单个任务并不能充分利用CPU时间.所以在单处理器的机器上也应该使用并发. <2>为了实现并发,操作系统层面提供了.但是进程的数量和开销都有限制,并且多个进程之间的数据共享比较麻烦.另一种比较轻量的并发实现是使用线程,一个进程可以包含多个线程.线程在进程中没有数量限制, 数据共享相对简单.线程的支持跟语言是有关系的.Java 语言中支持多线程. <3>Java 中的多线程是抢占式的.这意味着一个任

java中多线程的线程同步死锁问题

/* *定义一个多线程 */ package com.thread; public class TicketThread2 implements Runnable { //定义1000张票 public static int ticket = 100; Object obj = new Object(); // public boolean flag = false; // public boolean exit = false; @Override public void run() { //

Java:多线程,线程池,使用CompletionService通过Future来处理Callable的返回结果

1. 背景 在Java5的多线程中,可以使用Callable接口来实现具有返回值的线程.使用线程池的submit方法提交Callable任务,利用submit方法返回的Future存根,调用此存根的get方法来获取整个线程池中所有任务的运行结果. 方法一:如果是自己写代码,应该是自己维护一个Collection保存submit方法返回的Future存根,然后在主线程中遍历这个Collection并调用Future存根的get()方法取到线程的返回值. 方法二:使用CompletionServic

java核心技术-多线程之线程基础

说起线程,无法免俗首先要弄清楚的三个概念就是:进程.线程.协程.OK,那什么是进程,什么是线程,哪协程又是啥东西.进程:进程可以简单的理解为运行在操作系统中的程序,程序时静态代码,进程是动态运行着的代码,程序的运行需要向操作系统申请资源比如内存,文件句柄等,特别强调的是进程申请的资源都是独立的,也就是进程与进程之间资源是独立的.它被操作系统调度,所以进程是相对于操作系统的:线程:线程是进程中程序执行任务的那个,它共享着进程申请的资源:协程:可以简单的说是线程制造的轻量线程.讲完了基本的概念看看三

Java创建多线程和线程安全集合Vector

public class Test { public static Vector<String> data = new Vector<String>(); public static void main(String[] args) { for (int i = 0; i < 100; i++) { data.add("data" + i); } for (int i = 0; i < 3; i++) { Thread t = new Thread(

Java多线程之线程的创建

好久没有更博客了,最近一直在忙工作的事情.现在终于空下来了,这2天会抓紧时间整理多线程和socket,把JavaSE结束掉. 关于多线程,首先会涉及到哪些东西呢?首先要了解线程,为什么要使用线程,线程有什么优势,线程和进程有什么区别呢?了解过大致的线程内容后,就应该编码来实现Java的多线程了.首先2种方式来创建线程类,然后调用对应的API来控制线程.然后还剩下一个最大的也是最重要的一块知识,就是线程同步.前面那些了解线程的生命周期就可以,实际编码中并不会多次写到那些编码,但是线程的同步经常要用

Java并发学习之四——操作线程的中断机制

本文是学习网络上的文章时的总结,感谢大家无私的分享. 1.如果线程实现的是由复杂算法分成的一些方法,或者他的方法有递归调用,那么我们可以用更好的机制来控制线程中断.为了这个Java提供了InterruptedException异常.当你检测到程序的中断并在run()方法内捕获,你可以抛这个异常. 2.InterruptedException异常是由一些与并发API相关的Java方法,如sleep()抛出的. 下面以程序解释 package chapter; import java.io.File

Java多线程开发系列之四:玩转多线程(线程的控制1)

在前文中我们已经学习了:线程的基本情况.如何创建多线程.线程的生命周期.利用已有知识我们已经可以写出如何利用多线程处理大量任务这样简单的程序.但是当应用场景复杂时,我们还需要从管理控制入手,更好的操纵多线程.在第一节中我们讲过,使用多线程的好处之一就是我们可以通过编码和已有类库更好的管理和控制多线程.接下来我会详细的介绍如何管理多线程,包括:对线程的等待.守护线程.线程的睡眠.线程的突然停止.线程的让步.线程的优先级等.由于内容比较多,本节先介绍前两部分:对线程的等待.守护线程 1.线程的等待

Java多线程 2 线程的生命周期和状态控制

一.线程的生命周期 线程状态转换图: 1.新建状态 用new关键字和Thread类或其子类建立一个线程对象后,该线程对象就处于新生状态.处于新生状态的线程有自己的内存空间,通过调用start方法进入就绪状态(runnable). 注意:不能对已经启动的线程再次调用start()方法,否则会出现Java.lang.IllegalThreadStateException异常. 2.就绪状态 处于就绪状态的线程已经具备了运行条件,但还没有分配到CPU,处于线程就绪队列(尽管是采用队列形式,事实上,把它