个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
25
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Java并发编程示例(三)：线程中断由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
一个多线程的Java程序，直到所有线程执行完成，整个程序才会退出。（需要注意的是，是所有非后台线程（non-daemon thread）执行完成；如果一个线程执行了System.exit()方法，程序也会退出。）有时，你想中止一个线程的执行，例如你想退出程序，或者你想取消一个正在执行的任务等.
Java提供了中断机制，可以让我们显式地中断我们想中止执行的线程。中断机制的一个特征就是我们可以检查线程是否已经被中断，进而决定是否响应中止请求。线程也可以忽略中止请求，继续执行.
在本节，我们所开发的示例程序将会创建一个线程，五秒钟后，利用中断机制强制中止这个线程.
知其然 。
按照下面步骤所示，完成示例程序.
1.创建一个名为PrimeGenerator的类，并且继承Thread类。代码如下:
2.重写run()方法，在方法中添加一个无限循环，在循环内，通过计算来检查从1开始的连续正整数是否为素数。如果是，则打印到控制台。代码如下:
3.在处理一个数字之后，通过调用isInterrupted()方法来检查线程是否被中断。如果该方法返回true，则向控制台打印一句话，然后中止线程执行。代码如下:
if (isInterrupted()) { System.out.println("The Prime Generator has been Interrupted"); return; } 。
。
number++; } } 。
。
4.实现isPrime()方法，该方法用于判断参数是否为素数，如果是则返回true，否则返回false。代码如下:
/** * 判断参数是否为素数 * * @param number 需要判断的数字 * @return */ private boolean isPrime(long number) { if (number <= 2) { return true; } 。
。
for (int i = 2; i < number; i++) { if ((number % i) == 0) { return false; } } 。
return true; } 。
5.现在，实现示例程序的主类，Main类，同时实现main()方法。代码如下:
6.创建一个PrimeGenerator对象，并且启动该线程。代码如下:
7.等待五秒钟，然后中止该线程。代码如下:
try { TimeUnit.SECONDS.sleep(5L); } catch (InterruptedException e) { e.printStackTrace(); } 。
。
task.interrupt(),
8.运行该示例，查看结果.
。
知其所以然 。
下面的是示例程序执行的打印片段。我们从打印出的字符可以看出PrimeGenerator线程是如何打印输出信息以及当检测到线程被中断时，如何中止其执行的.
。
Thread有一个布尔型的熟悉，来表明线程是否被中断。当调用interrupt()方法时，就是将其设置为true。而isInterrupted()方法则是返回该属性的当前值.
永无止境 。
Thread还有一个可以检查线程是否中断的方法：即静态方法interrupted()，可以检查当前正在执行的线程是否被中断.
。
。
正如前面所述，线程可以忽略中断请求而继续执行。但是，这并不是我们想要的结果.
拿来主义 。
本文是从 《Java 7 Concurrency Cookbook》 （D瓜哥窃译为 《Java7并发示例集》 ）翻译而来，仅作为学习资料使用。没有授权，不得用于任何商业行为.
小有所成 。
示例程序所用的所有代码的完整版本.
PrimeGenerator类的完整代码 。
package com.diguage.books.concurrencycookbook.chapter1.recipe3,
。
/** * Date: 2013-09-18 * Time: 11:53 */ public class PrimeGenerator extends Thread { 。
@Override public void run() { long number = 1L; while (true) { if (isPrime(number)) { System.out.printf("Number %d \tis Prime.\n", number); } 。
if (isInterrupted()) { System.out.println("The Prime Generator has been Interrupted"); return; } 。
number++; } } 。
/** * 判断参数是否为素数 * * @param number 需要判断的数字 * @return */ private boolean isPrime(long number) { if (number <= 2) { return true; } 。
for (int i = 2; i < number; i++) { if ((number % i) == 0) { return false; } } 。
return true; } } 。
。
Main类的完整代码 。
。
package com.diguage.books.concurrencycookbook.chapter1.recipe3,
。
import java.util.concurrent.TimeUnit,
/** * Date: 2013-09-18 * Time: 12:33 */ public class Main { public static void main(String[] args) { Thread task = new PrimeGenerator(); task.start(),
try { TimeUnit.SECONDS.sleep(5L); } catch (InterruptedException e) { e.printStackTrace(); } 。
task.interrupt(); } } 。
。
最后此篇关于Java并发编程示例(三)：线程中断的文章就讲到这里了,如果你想了解更多关于Java并发编程示例(三)：线程中断的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
25
4
0
我正在尝试在多线程环境中实现某种累积逻辑；我想知道没有 lock 和 synchronized 关键字是否有更好/更快的方法来做到这一点？以下是我当前的代码: public class Concurr
我需要帮助构建一个实现信号量的监视器，简单的 C 示例就可以。 这是为了证明可以在任何可以使用信号量的地方使用监视器。 最佳答案 如果您说允许使用互斥锁/condvars，请检查: #include
我已经构建了一些返回部分产品目录的 ajax，并且我正在尝试将 xml 输出到文档中，到目前为止，这是我所拥有的: $("#catalog").append("Item NamePriceDe
很抱歉，如果我的问题之前已经被问过，或者它太明显了，但我真的需要澄清这一点。感谢您的帮助。 在多用户界面中，如果来自不同用户的相同事务同时到达服务器，会发生什么？ 我有下一张表: create tab
这可能是一个愚蠢的问题，但是这个程序的输出(它的方式)可以为零吗？ public class Test2{ int a = 0; AtomicInteger b = new Atomi
假设我本地主机上的一个网站处理每个请求大约需要 3 秒。这很好，正如预期的那样(因为它在幕后进行了一些奇特的网络)。 但是，如果我在选项卡(在 firefox 中)中打开相同的 url，然后同时重新加
我对 MongoDB 的读锁定有点困惑。单个集合可以支持多少个并发读取操作？ 最佳答案 如 tk 给出的链接中所写:http://www.mongodb.org/pages/viewpage.acti
如果有四个并发的 CUDA 应用程序在一个 GPU 中竞争资源会发生什么这样他们就可以将工作卸载到图形卡上了？ Cuda Programming Guide 3.1 提到那里 某些方法是异步的: 内核
👊上次的百度面试遇到了关于spark的并发数的问题，今天我们就来将这些问题都一并解决一下，图画的的有点丑，还行大家见谅，百度实习的问题我放在了下面的链接👇： 链接: 2022百度大数据开发工程师实
我对 Groovy 线程有疑问。 我的任务是以某种方式翻译给定目录中的每个文件 并将生成的输出放在其他目录中的文件中。 我编写了以下代码，该代码有效: static def translateDir(
Java中的同步和锁定有什么区别？ 最佳答案 synchronized是语言关键字；锁是对象。 当一个方法或代码块被标记为同步时，您是说该方法或代码块必须先获得某个锁对象(可以在同步的语法中指定)才能
我需要创建一个能够同时处理来自客户端的多个请求的并发 RPC 服务器。 使用 rpcgen linux编译器(基于sun RPC)，不支持-A为并发服务器创建 stub 的选项。 (-A 选项在 so
System.out.println("Enter the number of what you would like to do"); System.out.println("1 = Manuall
我正在将我的应用程序移植到 iOS 8.0 并注意到 UIAlertView 已被弃用。 所以我改变了使用 UIAlertController 的方法。这在大多数情况下都有效。 除了，当我的应用程序打
我正在逐行同时读取两个文本文件。 我特别想做的是当lineCount在每个线程上都是相同的我想看看扫描仪当前正在读取的字符串。 我环顾四周寻找可以实现的某些模式，例如 Compare and Swap
我正在阅读 Java Concurrency in Practice .在章节中断政策部分 取消和关闭 它提到 A task should not assume anything about the
我正在尝试学习线程，互斥等的基础知识。遵循here的文档和示例。在下面的代码中，我得到预期的输出。问题: 想确认我是否有任何陷阱？我们如何改善下面的代码？ 我的线程在哪一行尝试获取互斥锁或正在等待互斥
并发是指两个任务在不同的线程上并行运行。但是，异步方法并行运行，但在同一个线程上。这是如何实现的？另外，并行性怎么样？ 这三个概念有什么区别？ 最佳答案 并发和并行实际上与您正确推测的原理相同，两者都
以此ConcurrentDouble类定义为例: public class ConcurrentDouble { public double num = 0; public void subt
在得知并发确实增加了许多人的吞吐量后，我一直计划在项目中使用并发。现在我在多线程或并发方面还没有做太多工作，因此决定在实际项目中使用它之前学习并进行简单的概念验证。 以下是我尝试过的两个示例: 1.
我是一名优秀的程序员,十分优秀！