在Java中，在另一个线程的run方法中中断一个线程

Question

我正在阅读这篇文章，关于从一个线程中断另一个线程的建议是

“”“如果正确实施，以下几种方法应该可以奏效。

您可以让两个线程定期检查一些常见的标志变量（例如，将其称为stopNow），并安排两个线程在完成时进行设置。（标志变量需要是volatile…或正确同步的。）

您可以让两个线程定期调用线程。isInterrupted（）方法，查看它是否已被中断。然后每个线程都需要调用线程。完成后，在另一个上中断（）。" " "

我不明白第二种方法是如何使用线程的。isInterrupted（）。也就是说，如何调用线程1。线程2上的中断（）。

考虑这个例子，在main方法中，我启动了两个线程t1和t2。我想在达到一定条件后停止t1。我怎样才能做到这一点？

    class Thread1 extends Thread {
        
        
        public void run(){
            while (!isDone){
                // do something 
            }
        }        //now interrupt Thread-2
    }
    
    class Thread2 extends Thread {
        
        public void run(){
            try {
                     while(!Thread.isInterupted()){
                     //do something;
               }
               catch (InterruptedExecption e){
                    //do something               
                }
       }
}
        
    
    public class test {
        
        public static void main(String[] args){
        
        
        try {

            Thread1 t1 = new Thread1();
            Thread2 t2 = new Thread2();
            t1.start();
            t2.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
        }
        
    
    }

Answer 1

您可以考虑使用未来的界面。它提供了一个取消方法。http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html

Answer 2

public class test {

private static boolean someCondition = true;


public static void main(String[]args){

    Thread t2 = new Thread(new someOtherClass("Hello World"));
    Thread t1 = new Thread(new someClass(t2));
    t2.start();
    t1.start();
    try {
        t1.join();
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

}

static class someClass implements Runnable{

    Thread stop;
    public someClass(Thread toStop){
        stop = toStop;
    }


    public void run(){
        while(true){
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            if(someCondition && !stop.isInterrupted()){

                stop.interrupt();

            } 
        }
    }
}

static class someOtherClass implements Runnable{
    String messageToPrint;

    public someOtherClass(String s){
        messageToPrint = s;
    }

    public void run(){

        while(true){
            try {

                Thread.sleep(500);


            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }


            System.out.println(messageToPrint);
        }
    }
}

}

Answer 3

这里的上下文是您正在尝试使用线程中断来实现您的方案。

为了实现这一点，t1对象需要引用t2线程对象，然后它只调用t2。中断（）。

t1可以通过多种方式获取对t2的引用。

• 它可以作为构造函数参数传递。（您需要在Thread1之前实例化Thread2…）
• 可以通过调用Thread1上的setter来设置它
• 它可以从静态变量或数组中检索，也可以从某种单一的“注册表”对象中检索
• 可以通过枚举ThreadGroup中的所有线程来查找与t2名称匹配的线程