无法停止执行

Question

我开发了一个应用程序，旨在允许用户执行查询。一旦用户输入查询并单击执行按钮，控件就会传递给 RMI 服务器，然后启动线程。

用户应该能够一个接一个地执行其他查询，每个查询将在不同的线程中执行。

我无法停止线程的执行。我想在执行时停止执行，或者根据传递的线程 ID 在按钮单击事件上停止执行。 我正在尝试下面的代码

public class AcQueryExecutor implements Runnable {  
    private volatile boolean paused = false;     
    private volatile boolean finished = false;  
    String request_id="",usrnamee="",pswd="",driver="",url="";   

    public AcQueryExecutor(String request_id,String usrnamee,String pswd,String driver,String url) {  
        this.request_id=request_id;   
        this.usrnamee=usrnamee;   
        this.pswd=pswd;   
        this.url=url;   
        this.driver=driver;   
    }   

    public void upload() throws InterruptedException {   
        //some code                
        stop();
        //some more code
    }   

    public void run() {   
        try {   
            while(!finished) {   
                upload();   
            }
        } catch (InterruptedException e) {   
            e.printStackTrace();   
        }   
    }   

    public void stop() {
        finished = true; 
    }
}  

RMI 服务器类从我开始线程的地方

        public class ExecutorServer extends UnicastRemoteObject implements ExecutorInterface

        {
        public ExecutorServer()throws RemoteException
        {
        System.out.println("Server is in listening mode");
        }
        public void executeJob(String req_id,String usrname,String pwd,String driver,String url)throws RemoteException  
{
    try{
    System.out.println("Inside executeJob.wew..");
    AcQueryExecutor a=new AcQueryExecutor(req_id,usrname,pwd,driver,url);
    Thread t1 = new Thread(a);
    t1.start();
    }
    catch(Exception e)
    {
        System.out.println("Exception " + e);
    }

}           
        public void killJob(String req_id)throws RemoteException{
            logger.debug("Kill task");  
            AcQueryExecutor a=new AcQueryExecutor(req_id,"","","","");
    a.stop();
                    }


        public static void main(String arg[])
        {
        try{
            LocateRegistry.createRegistry(2007);
        ExecutorServer p=new ExecutorServer();
        Naming.rebind("//localhost:2007/exec1",p);
        System.out.println ("Server is connected and ready for operation.");
        }catch(Exception e)
        {
        System.out.println("Exception occurred : "+e.getMessage());
        e.printStackTrace();
        }
        }
               }

RMI 客户端

 ExecutorInterface p=(ExecutorInterface)Naming.lookup("//localhost:2007/exec1");
            System.out.println("Inside client.."+ p.toString());
                   p.executeJob(id, usrname, pswd);
                 p.killJob(id);
            }

直到我的知识 p.killJob() 将不会被调用，直到 executeJob() 完成。 我想在运行时停止执行

Answer 1

问题似乎是您正在为每个线程分配Runnable AcQueryExecutor 的新实例。这意味着每个人都看到了自己的finished 标志。在killJob 中设置一个不会导致任何其他线程退出，因为没有其他线程共享此标志。

您需要分享Runnables 或将finish 字段设为static。每当调用任何实例的 stop 时，后者都会导致所有线程退出，因此可能不是您想要的。