0

我开发了一个应用程序，旨在允许用户执行查询。一旦用户输入查询并单击执行按钮，控件就会传递给 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() 完成。我想在运行时停止执行

4

1 回答 1

0

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

您需要 share Runnables 或创建finishfield static。后者将导致所有线程在任何实例stop被调用时退出，因此可能不是您想要的。

于 2012-06-14T06:47:59.003 回答