首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 开发语言 > 编程 >

关于StreamGobbler读取Stream的线程同步有关问题

2012-12-25 
关于StreamGobbler读取Stream的线程同步问题使用Java Runtime执行系统命令时,有时候会定义一个类似StreamG

关于StreamGobbler读取Stream的线程同步问题
使用Java Runtime执行系统命令时,有时候会定义一个类似StreamGobbler的Thread来异步读取命令的输出,有的时候会遇到主进程关闭了Stream而StreamGobbler还没有读完Stream的情况,这样就会抛出类似"bad file descriptor stream closed"的IOException.

对于上述情况,一般使用synchronized关键字进行线程同步。具体做法如下:

1. 定义一个private synchronized的方法(例如work())来执行要进行的操作

private synchronized void work()
{
    // Add your code here
}

并且在Thread的run()方法调用该方法,这样当线程运行的时候就会锁住StreamGobbler对象。

public void run()
{
   work();
}

2. 定义一个
public synchronized boolean waitFor()
{
    return true;
}
该方法需要在销毁Runtime的Process对象之前执行,调用该方法时,如果StreamGobbler还在运行,StreamGobbler对象会被锁住,那么对该方法调用会进入等待状态直到work()执行完毕释放锁。

这样就可以保证,先执行完读取Stream内容,后关闭Stream。

说到底就是一个线程同步问题

热点排行