欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

java中的线程停止

程序员文章站 2022-07-13 10:58:36
...
想象一下这个场景,用户刚刚点了连接数据库后,忽然想起这个数据库没有启动,要等到默认的timeout(比如30秒后),连接才会停止,这时用户想立刻停止连接数据库的动作,怎么处理呢?
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资源