并发编程实战 1.3. 线程的中断 - interrupt()与isInterrupted()
并发编程实战 1.3. 线程的中断 - interrupt()与isInterrupted()
火犀牛 发表于2年前
并发编程实战 1.3. 线程的中断 - interrupt()与isInterrupted()
  • 发表于 2年前
  • 阅读 12
  • 收藏 0
  • 点赞 2
  • 评论 0

标题:腾讯云 新注册用户域名抢购1元起>>>   

摘要: 范例: 打印质数,2秒后结束

Java 提供了中断几只,我们可以使用它来结束一个线程。这种机制要求线程检查它是否被中断了,然决定是不是响应这个中断请求,或者继续执行。

范例:打印质数,2秒后结束

方法一:手动控制

package com.rr.concurrent.chapter1.recipe3.test;

/**
 * Created by isaac_gu on 2016/5/10.
 */
public class Task implements Runnable {

    @Override
    public void run() {
        Thread thread = Thread.currentThread();
        int i = 0;
        while (i++ >= 0) {
            if (thread.isInterrupted()) {
                System.out.println("线程被打断了!");
                //return;
                System.exit(0);
            } else if (isPrime(i)) {
                System.out.printf("%d 是 质数\r\n", i);
            }
        }
    }

    /**
     * 百度百科的实现方法
     *
     * @param n
     * @return
     */
    public static boolean isPrime(long n) {
        if (n <= 3) {
            return n > 1;
        }
        if (n % 2 == 0 || n % 3 == 0) {
            return false;
        }

        for (int i = 5; i * i <= n; i += 6) {
            if (n % i == 0 || n % (i + 2) == 0) {
                return false;
            }
        }
        return true;
    }
}

测试:

package com.rr.concurrent.chapter1.recipe3.test;


import java.util.concurrent.TimeUnit;

/**
 * Created by isaac_gu on 2016/5/10.
 * 打印质数,2秒后结束
 */
public class Test {
    public static void main(String[] args) {
        Thread thread = new Thread(new Task());
        thread.start();

        //睡眠2秒
        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        //2秒后打断
        thread.interrupt();

    }


}

检查线程是否被中断的方法有两种: isInterrupted() 和 静态方法Thread.interrupted();

方法二: 使用异常

package com.rr.current2.c1_3_interruptException.test;

/**
 * Created by Isaac on 16-5-10.
 */

/**
 * Created by isaac_gu on 2016/5/10.
 */
public class Task implements Runnable {

    @Override
    public void run() {
        try {
            print();
        } catch (InterruptedException e) {
            System.out.printf("%s: 线程被打断了!", Thread.currentThread().getName());
        }
    }

    public void print() throws InterruptedException {
        int i = 0;
        while (i++ >= 0) {
            if(Thread.interrupted()){
                throw new InterruptedException();
            } else if (isPrime(i)) {
                System.out.printf("%d 是 质数\r\n", i);
            }
        }
    }
    /**
     * 百度百科的实现方法
     *
     * @param n
     * @return
     */
    public static boolean isPrime(long n) {
        if (n <= 3) {
            return n > 1;
        }
        if (n % 2 == 0 || n % 3 == 0) {
            return false;
        }

        for (int i = 5; i * i <= n; i += 6) {
            if (n % i == 0 || n % (i + 2) == 0) {
                return false;
            }
        }
        return true;
    }
}

 

共有 人打赏支持
粉丝 0
博文 27
码字总数 12180
×
火犀牛
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: