本文来自:高爽|Coder,原文地址:http://blog.csdn.net/ghsau/article/details/17560467,转载请注明。
最近在Review线程专栏,修改了诸多之前描述不够严谨的地方,凡是带有Review标记的文章都是修改过了。本篇文章是插进来的,因为原来没有写,现在来看传统线程描述的不太完整,所以就补上了。理解了线程同步和线程通信之后,再来看本文的知识点就会简单的多了,本文是做为传统线程知识点的一个补充。有人会问:JDK5之后有了更完善的处理多线程问题的类(并发包),我们还需要去了解传统线程吗?答:需要。在实际开发中,无外乎两种情况,一个是开发新内容,另一个是维护原有程序。开发新内容可以使用新的技术手段,但是我们不能保证原有程序是用什么实现的,所以我们需要了解原有的。另外一点,了解传统线程的工作原理,使我们在使用并发包时更加得心应手。
线程中断
void |
interrupt() 中断线程。 |
static boolean |
interrupted() 测试当前线程是否已经中断。 |
boolean |
isInterrupted() 测试线程是否已经中断。 |
interrupt()方法用于中断线程,通常的理解来看,只要某个线程启动后,调用了该方法,则该线程不能继续执行了,来看个小例子:
- public class InterruptTest {
- public static void main(String[] args) throws InterruptedException {
- MyThread t = new MyThread("MyThread");
- t.start();
- Thread.sleep(100);// 睡眠100毫秒
- t.interrupt();// 中断t线程
- }
- }
- class MyThread extends Thread {
- int i = 0;
- public MyThread(String name) {
- super(name);
- }
- public void run() {
- while(true) {// 死循环,等待被中断
- System.out.println(getName() + getId() + "执行了" + ++i + "次");
- }
- }
- }
public class InterruptTest { public static void main(String[] args) throws InterruptedException { MyThread t = new MyThread("MyThread"); t.start(); Thread.sleep(100);// 睡眠100毫秒 t.interrupt();// 中断t线程 } } class MyThread extends Thread { int i = 0; public MyThread(String name) { super(name); } public void run() { while(true) {// 死循环,等待被中断 System.out.println(getName() + getId() + "执行了" + ++i + "次"); } } }
运行后,我们发现,线程t一直在执行,没有被中断,原来interrupt()是骗人的,汗!其实interrupt()方法并不是中断线程的执行,而是为调用该方法的线程对象打上一个标记,设置其中断状态为true,通过isInterrupted()方法可以得到这个线程状态,我们将上面的程序做一个小改动:
- public class InterruptTest {
- public static void main(String[] args) throws InterruptedException {
- MyThread t = new MyThread("MyThread");
- t.start();
- Thread.sleep(100);// 睡眠100毫秒
- t.interrupt();// 中断t线程
- }
- }
- class MyThread extends Thread {
- int i = 0;
- public MyThread(String name) {
- super(name);
- }
- public void run() {
- while(!isInterrupted()) {// 当前线程没有被中断,则执行
- System.out.println(getName() + getId() + "执行了" + ++i + "次");
- }
- }
- }
public class InterruptTest { public static void main(String[] args) throws InterruptedException { MyThread t = new MyThread("MyThread"); t.start(); Thread.sleep(100);// 睡眠100毫秒 t.interrupt();// 中断t线程 } } class MyThread extends Thread { int i = 0; public MyThread(String name) { super(name); } public void run() { while(!isInterrupted()) {// 当前线程没有被中断,则执行 System.out.println(getName() + getId() + "执行了" + ++i + "次"); } } }
这样的话,线程被顺利的中断执行了。很多人实现一个线程类时,都会再加一个flag标记,以便控制线程停止执行,其实完全没必要,通过线程自身的中断状态,就可以完美实现该功能。如果线程在调用 Object 类的 wait()、wait(long) 或 wait(long, int) 方法,或者该类的 join()、join(long)、join(long, int)、sleep(long) 或 sleep(long, int) 方法过程中受阻,则其中断状态将被清除,它还将收到一个 InterruptedException。 我们可以捕获该异常,并且做一些处理。另外,Thread.interrupted()方法是一个静态方法,它是判断当前线程的中断状态,需要注意的是,线程的中断状态会由该方法清除。换句话说,如果连续两次调用该方法,则第二次调用将返回 false(在第一次调用已清除了其中断状态之后,且第二次调用检验完中断状态前,当前线程再次中断的情况除外)。
线程让步
static void |
yield() 暂停当前正在执行的线程对象,并执行其他线程 |
线程让步用于正在执行的线程,在某些情况下让出CPU资源,让给其它线程执行,来看一个小例子:
- public class YieldTest {
- public static void main(String[] args) throws InterruptedException {
- // 创建线程对象
- YieldThread t1 = new YieldThread("t1");
- YieldThread t2 = new YieldThread("t2");
- // 启动线程
- t1.start();
- t2.start();
- // 主线程休眠100毫秒
- Thread.sleep(100);
- // 终止线程
- t1.interrupt();
- t2.interrupt();
- }
- }
- class YieldThread extends Thread {
- int i = 0;
- public YieldThread(String name) {
- super(name);
- }
- public void run() {
- while(!isInterrupted()) {
- System.out.println(getName() + "执行了" + ++i + "次");
- if(i % 10 == 0) {// 当i能对10整除时,则让步
- Thread.yield();
- }
- }
- }
- }
public class YieldTest { public static void main(String[] args) throws InterruptedException { // 创建线程对象 YieldThread t1 = new YieldThread("t1"); YieldThread t2 = new YieldThread("t2"); // 启动线程 t1.start(); t2.start(); // 主线程休眠100毫秒 Thread.sleep(100); // 终止线程 t1.interrupt(); t2.interrupt(); } } class YieldThread extends Thread { int i = 0; public YieldThread(String name) { super(name); } public void run() { while(!isInterrupted()) { System.out.println(getName() + "执行了" + ++i + "次"); if(i % 10 == 0) {// 当i能对10整除时,则让步 Thread.yield(); } } } }
输出结果略,从输出结果可以看到,当某个线程(t1或者t2)执行到10次、20次、30次等时,就会马上切换到另一个线程执行,接下来再交替执行,如此往复。注意,如果存在synchronized线程同步的话,线程让步不会释放锁(监视器对象)。
线程睡眠
static void |
sleep(long millis) 在指定的毫秒数内让当前正在执行的线程休眠(暂停执行)。 |
static void |
sleep(long millis, int nanos) 在指定的毫秒数加指定的纳秒数内让当前正在执行的线程休眠(暂停执行)。 |
线程睡眠的过程中,如果是在synchronized线程同步内,是持有锁(监视器对象)的,也就是说,线程是关门睡觉的,别的线程进不来,来看一个小例子:
- public class SleepTest {
- public static void main(String[] args) {
- // 创建共享对象
- Service service = new Service();
- // 创建线程
- SleepThread t1 = new SleepThread("t1", service);
- SleepThread t2 = new SleepThread("t2", service);
- // 启动线程
- t1.start();
- t2.start();
- }
- }
- class SleepThread extends Thread {
- private Service service;
- public SleepThread(String name, Service service) {
- super(name);
- this.service = service;
- }
- public void run() {
- service.calc();
- }
- }
- class Service {
- public synchronized void calc() {
- System.out.println(Thread.currentThread().getName() + "准备计算");
- System.out.println(Thread.currentThread().getName() + "感觉累了,开始睡觉");
- try {
- Thread.sleep(10000);// 睡10秒
- } catch (InterruptedException e) {
- return;
- }
- System.out.println(Thread.currentThread().getName() + "睡醒了,开始计算");
- System.out.println(Thread.currentThread().getName() + "计算完成");
- }
- }
public class SleepTest { public static void main(String[] args) { // 创建共享对象 Service service = new Service(); // 创建线程 SleepThread t1 = new SleepThread("t1", service); SleepThread t2 = new SleepThread("t2", service); // 启动线程 t1.start(); t2.start(); } } class SleepThread extends Thread { private Service service; public SleepThread(String name, Service service) { super(name); this.service = service; } public void run() { service.calc(); } } class Service { public synchronized void calc() { System.out.println(Thread.currentThread().getName() + "准备计算"); System.out.println(Thread.currentThread().getName() + "感觉累了,开始睡觉"); try { Thread.sleep(10000);// 睡10秒 } catch (InterruptedException e) { return; } System.out.println(Thread.currentThread().getName() + "睡醒了,开始计算"); System.out.println(Thread.currentThread().getName() + "计算完成"); } }
输出结果:
- t1准备计算
- t1感觉累了,开始睡觉
- t1睡醒了,开始计算
- t1计算完成
- t2准备计算
- t2感觉累了,开始睡觉
- t2睡醒了,开始计算
- t2计算完成
t1准备计算 t1感觉累了,开始睡觉 t1睡醒了,开始计算 t1计算完成 t2准备计算 t2感觉累了,开始睡觉 t2睡醒了,开始计算 t2计算完成
线程合并
void |
join() 等待该线程终止。 |
void |
join(long millis) 等待该线程终止的时间最长为 millis 毫秒。 |
void |
join(long millis, int nanos) 等待该线程终止的时间最长为 millis 毫秒 + nanos 纳秒。 |
- public class JoinTest {
- public static void main(String[] args) throws InterruptedException {
- JoinThread t1 = new JoinThread("t1");
- JoinThread t2 = new JoinThread("t2");
- t1.start();
- t2.start();
- t1.join();
- t2.join();
- System.out.println("主线程开始执行!");
- }
- }
- class JoinThread extends Thread {
- public JoinThread(String name) {
- super(name);
- }
- public void run() {
- for(int i = 1; i <= 10; i++)
- System.out.println(getName() + getId() + "执行了" + i + "次");
- }
- }
public class JoinTest { public static void main(String[] args) throws InterruptedException { JoinThread t1 = new JoinThread("t1"); JoinThread t2 = new JoinThread("t2"); t1.start(); t2.start(); t1.join(); t2.join(); System.out.println("主线程开始执行!"); } } class JoinThread extends Thread { public JoinThread(String name) { super(name); } public void run() { for(int i = 1; i <= 10; i++) System.out.println(getName() + getId() + "执行了" + i + "次"); } }t1和t2都执行完才继续主线程的执行,所谓合并,就是等待其它线程执行完,再执行当前线程,执行起来的效果就好像把其它线程合并到当前线程执行一样。
线程优先级
public static final int |
MAX_PRIORITY |
10 |
public static final int |
MIN_PRIORITY |
1 |
public static final int |
NORM_PRIORITY |
5 |
wait()和sleep()区别
最近在Review线程专栏,修改了诸多之前描述不够严谨的地方,凡是带有Review标记的文章都是修改过了。本篇文章是插进来的,因为原来没有写,现在来看传统线程描述的不太完整,所以就补上了。理解了线程同步和线程通信之后,再来看本文的知识点就会简单的多了,本文是做为传统线程知识点的一个补充。有人会问:JDK5之后有了更完善的处理多线程问题的类(并发包),我们还需要去了解传统线程吗?答:需要。在实际开发中,无外乎两种情况,一个是开发新内容,另一个是维护原有程序。开发新内容可以使用新的技术手段,但是我们不能保证原有程序是用什么实现的,所以我们需要了解原有的。另外一点,了解传统线程的工作原理,使我们在使用并发包时更加得心应手。
线程中断
void |
interrupt() 中断线程。 |
static boolean |
interrupted() 测试当前线程是否已经中断。 |
boolean |
isInterrupted() 测试线程是否已经中断。 |
- public class InterruptTest {
- public static void main(String[] args) throws InterruptedException {
- MyThread t = new MyThread("MyThread");
- t.start();
- Thread.sleep(100);// 睡眠100毫秒
- t.interrupt();// 中断t线程
- }
- }
- class MyThread extends Thread {
- int i = 0;
- public MyThread(String name) {
- super(name);
- }
- public void run() {
- while(true) {// 死循环,等待被中断
- System.out.println(getName() + getId() + "执行了" + ++i + "次");
- }
- }
- }
public class InterruptTest { public static void main(String[] args) throws InterruptedException { MyThread t = new MyThread("MyThread"); t.start(); Thread.sleep(100);// 睡眠100毫秒 t.interrupt();// 中断t线程 } } class MyThread extends Thread { int i = 0; public MyThread(String name) { super(name); } public void run() { while(true) {// 死循环,等待被中断 System.out.println(getName() + getId() + "执行了" + ++i + "次"); } } }运行后,我们发现,线程t一直在执行,没有被中断,原来interrupt()是骗人的,汗!其实interrupt()方法并不是中断线程的执行,而是为调用该方法的线程对象打上一个标记,设置其中断状态为true,通过isInterrupted()方法可以得到这个线程状态,我们将上面的程序做一个小改动:
- public class InterruptTest {
- public static void main(String[] args) throws InterruptedException {
- MyThread t = new MyThread("MyThread");
- t.start();
- Thread.sleep(100);// 睡眠100毫秒
- t.interrupt();// 中断t线程
- }
- }
- class MyThread extends Thread {
- int i = 0;
- public MyThread(String name) {
- super(name);
- }
- public void run() {
- while(!isInterrupted()) {// 当前线程没有被中断,则执行
- System.out.println(getName() + getId() + "执行了" + ++i + "次");
- }
- }
- }
public class InterruptTest { public static void main(String[] args) throws InterruptedException { MyThread t = new MyThread("MyThread"); t.start(); Thread.sleep(100);// 睡眠100毫秒 t.interrupt();// 中断t线程 } } class MyThread extends Thread { int i = 0; public MyThread(String name) { super(name); } public void run() { while(!isInterrupted()) {// 当前线程没有被中断,则执行 System.out.println(getName() + getId() + "执行了" + ++i + "次"); } } }
这样的话,线程被顺利的中断执行了。很多人实现一个线程类时,都会再加一个flag标记,以便控制线程停止执行,其实完全没必要,通过线程自身的中断状态,就可以完美实现该功能。如果线程在调用 Object 类的 wait()、wait(long) 或 wait(long, int) 方法,或者该类的 join()、join(long)、join(long, int)、sleep(long) 或 sleep(long, int) 方法过程中受阻,则其中断状态将被清除,它还将收到一个 InterruptedException。 我们可以捕获该异常,并且做一些处理。另外,Thread.interrupted()方法是一个静态方法,它是判断当前线程的中断状态,需要注意的是,线程的中断状态会由该方法清除。换句话说,如果连续两次调用该方法,则第二次调用将返回 false(在第一次调用已清除了其中断状态之后,且第二次调用检验完中断状态前,当前线程再次中断的情况除外)。
线程让步
static void |
yield() 暂停当前正在执行的线程对象,并执行其他线程 |
- public class YieldTest {
- public static void main(String[] args) throws InterruptedException {
- // 创建线程对象
- YieldThread t1 = new YieldThread("t1");
- YieldThread t2 = new YieldThread("t2");
- // 启动线程
- t1.start();
- t2.start();
- // 主线程休眠100毫秒
- Thread.sleep(100);
- // 终止线程
- t1.interrupt();
- t2.interrupt();
- }
- }
- class YieldThread extends Thread {
- int i = 0;
- public YieldThread(String name) {
- super(name);
- }
- public void run() {
- while(!isInterrupted()) {
- System.out.println(getName() + "执行了" + ++i + "次");
- if(i % 10 == 0) {// 当i能对10整除时,则让步
- Thread.yield();
- }
- }
- }
- }
public class YieldTest { public static void main(String[] args) throws InterruptedException { // 创建线程对象 YieldThread t1 = new YieldThread("t1"); YieldThread t2 = new YieldThread("t2"); // 启动线程 t1.start(); t2.start(); // 主线程休眠100毫秒 Thread.sleep(100); // 终止线程 t1.interrupt(); t2.interrupt(); } } class YieldThread extends Thread { int i = 0; public YieldThread(String name) { super(name); } public void run() { while(!isInterrupted()) { System.out.println(getName() + "执行了" + ++i + "次"); if(i % 10 == 0) {// 当i能对10整除时,则让步 Thread.yield(); } } } }
输出结果略,从输出结果可以看到,当某个线程(t1或者t2)执行到10次、20次、30次等时,就会马上切换到另一个线程执行,接下来再交替执行,如此往复。注意,如果存在synchronized线程同步的话,线程让步不会释放锁(监视器对象)。
线程睡眠
static void |
sleep(long millis) 在指定的毫秒数内让当前正在执行的线程休眠(暂停执行)。 |
static void |
sleep(long millis, int nanos) 在指定的毫秒数加指定的纳秒数内让当前正在执行的线程休眠(暂停执行)。 |
- public class SleepTest {
- public static void main(String[] args) {
- // 创建共享对象
- Service service = new Service();
- // 创建线程
- SleepThread t1 = new SleepThread("t1", service);
- SleepThread t2 = new SleepThread("t2", service);
- // 启动线程
- t1.start();
- t2.start();
- }
- }
- class SleepThread extends Thread {
- private Service service;
- public SleepThread(String name, Service service) {
- super(name);
- this.service = service;
- }
- public void run() {
- service.calc();
- }
- }
- class Service {
- public synchronized void calc() {
- System.out.println(Thread.currentThread().getName() + "准备计算");
- System.out.println(Thread.currentThread().getName() + "感觉累了,开始睡觉");
- try {
- Thread.sleep(10000);// 睡10秒
- } catch (InterruptedException e) {
- return;
- }
- System.out.println(Thread.currentThread().getName() + "睡醒了,开始计算");
- System.out.println(Thread.currentThread().getName() + "计算完成");
- }
- }
public class SleepTest { public static void main(String[] args) { // 创建共享对象 Service service = new Service(); // 创建线程 SleepThread t1 = new SleepThread("t1", service); SleepThread t2 = new SleepThread("t2", service); // 启动线程 t1.start(); t2.start(); } } class SleepThread extends Thread { private Service service; public SleepThread(String name, Service service) { super(name); this.service = service; } public void run() { service.calc(); } } class Service { public synchronized void calc() { System.out.println(Thread.currentThread().getName() + "准备计算"); System.out.println(Thread.currentThread().getName() + "感觉累了,开始睡觉"); try { Thread.sleep(10000);// 睡10秒 } catch (InterruptedException e) { return; } System.out.println(Thread.currentThread().getName() + "睡醒了,开始计算"); System.out.println(Thread.currentThread().getName() + "计算完成"); } }输出结果:
- t1准备计算
- t1感觉累了,开始睡觉
- t1睡醒了,开始计算
- t1计算完成
- t2准备计算
- t2感觉累了,开始睡觉
- t2睡醒了,开始计算
- t2计算完成
t1准备计算 t1感觉累了,开始睡觉 t1睡醒了,开始计算 t1计算完成 t2准备计算 t2感觉累了,开始睡觉 t2睡醒了,开始计算 t2计算完成
线程合并
void |
join() 等待该线程终止。 |
void |
join(long millis) 等待该线程终止的时间最长为 millis 毫秒。 |
void |
join(long millis, int nanos) 等待该线程终止的时间最长为 millis 毫秒 + nanos 纳秒。 |
- public class JoinTest {
- public static void main(String[] args) throws InterruptedException {
- JoinThread t1 = new JoinThread("t1");
- JoinThread t2 = new JoinThread("t2");
- t1.start();
- t2.start();
- t1.join();
- t2.join();
- System.out.println("主线程开始执行!");
- }
- }
- class JoinThread extends Thread {
- public JoinThread(String name) {
- super(name);
- }
- public void run() {
- for(int i = 1; i <= 10; i++)
- System.out.println(getName() + getId() + "执行了" + i + "次");
- }
- }
public class JoinTest { public static void main(String[] args) throws InterruptedException { JoinThread t1 = new JoinThread("t1"); JoinThread t2 = new JoinThread("t2"); t1.start(); t2.start(); t1.join(); t2.join(); System.out.println("主线程开始执行!"); } } class JoinThread extends Thread { public JoinThread(String name) { super(name); } public void run() { for(int i = 1; i <= 10; i++) System.out.println(getName() + getId() + "执行了" + i + "次"); } }t1和t2都执行完才继续主线程的执行,所谓合并,就是等待其它线程执行完,再执行当前线程,执行起来的效果就好像把其它线程合并到当前线程执行一样。
线程优先级
public static final int |
MAX_PRIORITY |
10 |
public static final int |
MIN_PRIORITY |
1 |
public static final int |
NORM_PRIORITY |
5 |
相关推荐
Java线程:线程的调度-让步 Java线程:线程的调度-合并 Java线程:线程的调度-守护线程 Java线程:线程的同步-同步方法 Java线程:线程的同步-同步块 Java线程:并发协作-生产者消费者模型 Java线程:并发协作-死锁...
#### 四、Java线程:线程栈模型与线程的变量 每个线程都拥有自己的调用栈,这意味着每个线程都有独立的执行路径。线程之间可以共享进程级别的资源,例如内存,但不能直接访问对方的局部变量或调用栈上的数据。 ###...
- **线程调度**:包括休眠、优先级调整、线程让步、合并线程以及守护线程的概念。 - **并发协作**:深入探讨了生产者-消费者模型和死锁问题,提供了理解和避免死锁的策略。 - **新特征**:Java 5引入的并发工具,如`...
Java中的线程让步是一种线程协作的方式,它允许一个正在执行的线程主动放弃当前的时间片,将CPU资源让给其他线程使用。这种方式在多线程编程中有时会用到,比如当一个线程完成某项任务后,希望其他线程能够优先执行...
#### 四、Java线程:线程状态的转换 - **线程的状态** Java线程的状态包括新建 (`NEW`)、就绪 (`RUNNABLE`)、阻塞 (`BLOCKED`)、等待 (`WAITING`)、超时等待 (`TIMED_WAITING`) 和终止 (`TERMINATED`)。 #### 五...
4. **线程合并与让步**:join()方法用于合并线程,让当前线程等待指定线程结束后再继续执行。yield()方法则是让当前线程暂停,让其他同优先级的线程有机会执行。 5. **守护线程(Daemon)**:守护线程是一种特殊的...
Java线程让步是多线程编程中一个重要的概念,主要涉及到如何控制线程的执行顺序和资源分配。`yield()`方法是Java提供的一种线程让步的方式,它允许当前正在执行的线程暂停,将执行权短暂地让给其他等待的线程,特别...
**四、Java线程:线程状态的转换** 线程有五种基本状态:新建、可运行、运行、阻塞和终止。状态之间的转换是由系统调度和线程的同步操作决定的。 **五、Java线程:线程的同步与锁** - **同步**:防止多个线程同时...
Java线程让步(Yield)是Java多线程编程中的一个重要概念,它涉及到线程调度和并发控制。在多线程环境下,线程让步意味着一个正在运行的线程主动放弃当前的时间片,以便其他就绪状态的线程有机会执行。这与线程的...
#### 十四、Java线程:新特征-锁(上) Java提供了一套高级的锁机制,如`ReentrantLock`,这允许更精细的锁控制。 #### 十五、Java线程:新特征-锁(下) 进一步探讨锁的高级用法,包括公平锁、非公平锁等。 ###...
#### 十四、Java线程:新特征-阻塞队列与阻塞栈 - **阻塞队列**: - `BlockingQueue` 是一种特殊类型的队列,它提供了额外的阻塞行为。 - 当队列为空时,从队列中取元素的操作将会阻塞;当队列满时,往队列里添加...
1. 线程控制:Java提供了丰富的API来控制线程,如`sleep()`, `join()`, `yield()`, `interrupt()`, `isInterrupted()`等,用于暂停、等待、让步和中断线程。 2. 线程同步:为了防止多个线程同时访问共享资源导致数据...
合并(线程合并),通过`join()`方法等待另一个线程结束;以及终止线程(`stop()`或`interrupt()`),结束线程的执行。值得注意的是,`stop()`方法已弃用,因为可能引起数据不一致,推荐使用`interrupt()`。 守护...
6. **线程让步**: - `public static void yield()`:使当前正在执行的线程放弃CPU,让给同优先级的其他线程执行。 7. **中断线程**: - `public void interrupt()`:中断当前线程。 8. **检查线程状态**: - `...
6. 线程的调度:Java线程模型提供了多种方式来控制线程的执行,如休眠(sleep)、优先级(setPriority)、让步(yield)等。 7. 并发协作模型:生产者消费者模型、死锁等都是并发协作的经典问题,Java通过并发工具...
Java线程学习笔记涉及了Java多线程编程的多个关键知识点,本篇知识点整理将详细解释每个概念及其在Java中的实现方式。 基本知识部分包含了Java线程编程的基础内容,它们是并发编程的基石。 任务Runnable是一个接口...