我写了一段scala代码:
val process = java.lang.Runtime.getRuntime.exec("testCin.exe")
val out = process.getOutputStream();
val Bufferedoutput=new BufferedOutputStream(out);
val file = Source.fromFile("part-user.file")
for(line<-file.getLines()){
Bufferedoutput.write((line+"\n").getBytes())
}
代码中使用的java函数,所以基本是java代码,,过程是这样的使用java.lang.Runtime.getRuntime.exec新建一个process,即执行testCin.exe,然后使用Bufferedoutput.write作标准输出,将part-user.file文件中读到的内容输出到testCin.exe中。
下面是testCin.exe的C++实现:
using namespace std;
int main(int argc, char *argv[]) {
string line;
while(getline(cin, line)) {
cout << "cin :"<< line << "\t" << endl;
}
return 0;
}
在testCin.exe中使用cin得到scala程序输出的数据,然后再处理,使用cout进行输出。
问题是:
每次Bufferedoutput.write执行几次(我输了大约8次)后就会停止,而testCin.exe也会停止,这样进入一个死锁状态,手动停止testCin.exe程序后,会从testCin.exe得到几句输出。当我把C++中的cout都注释掉后,程序会顺利进行。
网上说是因为缓冲区大小限制。我在网络上找了很多方法都不行,请问这个问题该怎么处理?_