在多线程开发中停止线程是很重要的技术点。停止线程在Java语言中并不像break语句那样干脆,需要一些技巧性的处理。
采用异常法来停止一个线程,首先我们需要了解一下两个方法的用法:
public class MyThread extends Thread{
@Override
public void run() {
for (int i = 1; i <= 10000; i++) {
System.out.println("i="+i);
}
}
public static void main(String[] args)throws Exception {
MyThread thread=new MyThread();
thread.start();
thread.sleep(10);
thread.interrupt();
}
}public class MyThread extends Thread{
@Override
public void run() {
for (int i = 1; i <= 10000; i++) {
System.out.println("i="+i);
}
}
public static void main(String[] args)throws Exception {
try{
MyThread thread=new MyThread();
thread.start();
thread.sleep(100);
thread.interrupt();
System.out.println("线程停止了吗1?--->"+thread.interrupted());
System.out.println("线程停止了吗2?--->"+thread.interrupted());
}catch(Exception e){
e.printStackTrace();
}
System.out.println("end");
}
}public class MyThread{
public static void main(String[] args){
Thread.currentThread().interrupt();
System.out.println("线程停止了吗1?---->"+Thread.interrupted());
System.out.println("线程停止了吗2?---->"+Thread.interrupted());
System.out.println("end");
}
}public class MyThread extends Thread{
@Override
public void run() {
for (int i = 1; i <= 10000; i++) {
System.out.println("i="+i);
}
}
public static void main(String[] args){
try{
MyThread thread=new MyThread();
thread.start();
thread.sleep(10);
thread.interrupt();
System.out.println("线程停止了吗1?--->"+thread.isInterrupted());
System.out.println("线程停止了吗2?--->"+thread.isInterrupted());
}catch(Exception e){
e.printStackTrace();
}
System.out.println("end");
}
}public class MyThread extends Thread{
@Override
public void run() {
for (int i = 1; i <= 10000; i++) {
if(this.interrupted()){
System.out.println("线程是停止状态了,我要退出了.");
break;
}
System.out.println("i="+i);
}
System.out.println("如果此处还是循环,那么我就会继续执行.线程并没有停止");
}
public static void main(String[] args){
try{
MyThread thread=new MyThread();
thread.start();
thread.sleep(10);
thread.interrupt();
System.out.println("end");
}catch(Exception e){
e.printStackTrace();
}
}
}public class MyThread extends Thread{
@Override
public void run() {
try{
for (int i = 1; i <= 10000; i++) {
if(this.interrupted()){
System.out.println("线程是停止状态了,我要退出了.");
throw new InterruptedException();
}
System.out.println("i="+i);
}
System.out.println("我被执行了吗?");
}catch(InterruptedException e){
System.out.println("---这次线程停了---");
e.printStackTrace();
}
}
public static void main(String[] args){
try{
MyThread thread=new MyThread();
thread.start();
thread.sleep(10);
thread.interrupt();
System.out.println("end");
}catch(Exception e){
e.printStackTrace();
}
}
}public class MyThread extends Thread{
@Override
public void run() {
try{
System.out.println("run start");
Thread.sleep(1000000);
System.out.println("run end");
}catch(InterruptedException e){
System.out.println("sleep被停止,状态:--->"+this.isInterrupted());
e.printStackTrace();
}
}
public static void main(String[] args){
try{
MyThread thread=new MyThread();
thread.start();
thread.interrupt();
thread.sleep(1000);
}catch(Exception e){
System.out.println("main catch");
e.printStackTrace();
}
}
}public class MyThread extends Thread{
@Override
public void run() {
try{
for (int i = 1; i <= 10000; i++) {
System.out.println("i="+i);
}
System.out.println("run start");
Thread.sleep(1000000);
System.out.println("run end");
}catch(InterruptedException e){
System.out.println("线程被停止了,在sleep,状态:--->"+this.isInterrupted());
e.printStackTrace();
}
}
public static void main(String[] args){
try{
MyThread thread=new MyThread();
thread.start();
thread.interrupt();
}catch(Exception e){
System.out.println("main catch");
e.printStackTrace();
}
}
}public class MyThread extends Thread{
private int i=0;
@Override
public void run() {
try{
while (true) {
i++;
System.out.println("i="+i);
Thread.sleep(1000);
}
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String[] args){
try{
MyThread thread=new MyThread();
thread.start();
Thread.sleep(6000);
thread.stop();
}catch(Exception e){
e.printStackTrace();
}
}
}public class MyThread extends Thread{
private int i=0;
@Override
public void run() {
try{
while (true) {
i++;
if(this.interrupted()){
System.out.println("线程停止了");
return;
}
System.out.println("i="+i);
}
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String[] args){
try{
MyThread thread=new MyThread();
thread.start();
Thread.sleep(2000);
thread.interrupt();
}catch(Exception e){
e.printStackTrace();
}
}
}版权声明:本文为博主原创文章,未经博主允许不得转载。
原文地址:http://blog.csdn.net/luckey_zh/article/details/46955739