java中的线程停止
程序员文章站
2022-07-13 10:58:36
...
想象一下这个场景,用户刚刚点了连接数据库后,忽然想起这个数据库没有启动,要等到默认的timeout(比如30秒后),连接才会停止,这时用户想立刻停止连接数据库的动作,怎么处理呢?
这是在一个线程里完成该任务,如果connectdatabase();非常慢的话,那么用户只能一直等
更好的做法是,让另外一个线程去处理连接动作,前台页面返回,让用户可以做别的事情,示意代码如下
这时用户发现数据库没有启动,想在页面中点一下终止连接按钮停止连接,比如在eclipse的IRunnableWithProgress中,虽然可以监听用户点击按钮,但是这时run 方法的线程和叫做"Cancel progress"的线程已经没有什么关系了,无法通过监听户点击终止按钮而使"Cancel progress"线程停下,这时可以用下面的方法
首先在父线程中,启动子线程,一般的正常流程是,父线程一直处于循环中,每次循环去判断子线程是否完成,(当然子线程完成后需要设置一下完成标志位),发现子线程结束后父线程跳出循环,继续执行后面的代码.当用户点击取消按钮后(pm.isCanceled()是IRunnableWithProgress中监听用户点击取消按钮时的动作),并且将子线程处理一下(比如回收一些垃圾等),方法返回,这样就可以达到目的了.另外重要的一点,父线程循环过程中记得sleep一下,给其他线程一些执行机会,节省cpu资源
public void run(final IProgressMonitor pm) throws InvocationTargetException { pm.beginTask(Messages.progressMetadata, IProgressMonitor.UNKNOWN); try { connector.connectdatabase(); }catch(Exception e){ LOG.error(e.getMessage(), e); }finally { pm.done(); } }
这是在一个线程里完成该任务,如果connectdatabase();非常慢的话,那么用户只能一直等
更好的做法是,让另外一个线程去处理连接动作,前台页面返回,让用户可以做别的事情,示意代码如下
public void run(final IProgressMonitor pm) throws InvocationTargetException { pm.beginTask(Messages.progressMetadata, IProgressMonitor.UNKNOWN); Thread thread = new Thread("Cancel progress"){ public void run() { connector.connectdatabase(); } }; thread.start(); }catch(Exception e){ LOG.error(e.getMessage(), e); }finally { pm.done(); } }
这时用户发现数据库没有启动,想在页面中点一下终止连接按钮停止连接,比如在eclipse的IRunnableWithProgress中,虽然可以监听用户点击按钮,但是这时run 方法的线程和叫做"Cancel progress"的线程已经没有什么关系了,无法通过监听户点击终止按钮而使"Cancel progress"线程停下,这时可以用下面的方法
public void run(final IProgressMonitor pm) throws InvocationTargetException { pm.beginTask(Messages.progressMetadata, IProgressMonitor.UNKNOWN); try { Thread thread = new Thread("Cancel progress"){ public void run() { connector.connectdatabase(); } }; thread.start(); while (true) { if(pm == null){ break; } if(pm.isCanceled()){ connector.gc(); thread.interrupt(); return; }else{ try { Thread.sleep(100); } catch (InterruptedException e) { LOG.error(e.getMessage(), e); } } if(connector.isFinish()){ break; } } }catch(Exception e){ LOG.error(e.getMessage(), e); }finally { pm.done(); } }
首先在父线程中,启动子线程,一般的正常流程是,父线程一直处于循环中,每次循环去判断子线程是否完成,(当然子线程完成后需要设置一下完成标志位),发现子线程结束后父线程跳出循环,继续执行后面的代码.当用户点击取消按钮后(pm.isCanceled()是IRunnableWithProgress中监听用户点击取消按钮时的动作),并且将子线程处理一下(比如回收一些垃圾等),方法返回,这样就可以达到目的了.另外重要的一点,父线程循环过程中记得sleep一下,给其他线程一些执行机会,节省cpu资源