欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

java使用Process調(diào)用exe程序及Process.waitFor()死鎖問題解決

 更新時間:2022年12月20日 09:05:42   作者:小肥羊沖沖沖  
在編寫Java程序時,有時候我們需要調(diào)用其他的諸如exe,shell這樣的程序或腳本,下面這篇文章主要給大家介紹了關(guān)于java使用Process調(diào)用exe程序及Process.waitFor()死鎖問題解決的相關(guān)資料,需要的朋友可以參考下

前言

最近在開發(fā)android的同時也在開發(fā)java ,碰到了需要使用java 程序調(diào)用exe的需求,這里我使用的 process 來調(diào)用的。該篇文章 讀完需要8+分鐘,文章類型為 小白入門類型,此處主要記錄,方便以后學習補充… 如有不正確的地方還望海涵 及 指出….

文章參考

process參考

waitfor掛起解析

1. 使用process調(diào)用exe程序

ProcessBuilder pb = new ProcessBuilder("C:\\Debug\\TestRedis.exe", keyNmae);
pb.redirectErrorStream(true);
Process process = pb.start();
//可能導致進程阻塞,甚至死鎖
int ret = process.waitFor();
System.out.println("return value:"+ret);
System.out.println(process.exitValue());
byte[] bytes = new byte[process.getInputStream().available()];
process.getInputStream().read(bytes);
System.out.println(new String(bytes));
// ProcessBuilder api 方法
public ProcessBuilder(String... command) {
        this.command = new ArrayList<>(command.length);
        for (String arg : command)
            this.command.add(arg);
    }

首先我們先使用 processBuilder 創(chuàng)建出該對象,該對象我這里暫時使用了第一個參數(shù)為 exe 文件的地址,第二個參數(shù)為傳遞參數(shù),是我需要傳給exe 的字符串。后邊主要就是打印 輸入流,獲取exe 輸出信息。其實到這里java 調(diào)用exe 就已經(jīng)完 了,但是后續(xù)開發(fā)中遇到一種問題,就是程序莫名死鎖,沒有響應(yīng),于是使用debug 跟進代碼,發(fā)現(xiàn)程序走到 waitfor 代碼行的時候程序就出現(xiàn)了掛起的情況,于是google了一番,明白了其中的原因。

2. waitfor 問題描述分析

1.主進程中調(diào)用pb.start會創(chuàng)建一個子進程,用于執(zhí)行shell /exe 腳本。子進程創(chuàng)建后會和主進程分別獨立運行。

2. 因為主進程需要等待腳本執(zhí)行完成,然后對腳本返回值或輸出進行處理,所以這里主進程調(diào)用Process.waitfor等待子進程完成。

3. 子進程執(zhí)行過程就是不斷的打印信息。主進程中可以通過Process.getInputStream和Process.getErrorStream獲取并處理。

4. 這時候子進程不斷向主進程發(fā)生數(shù)據(jù),而主進程調(diào)用Process.waitfor后已掛起。當前子進程和主進程之間的緩沖區(qū)塞滿后,子進程不能繼續(xù)寫數(shù)據(jù),然后也會掛起。

5. 這樣子進程等待主進程讀取數(shù)據(jù),主進程等待子進程結(jié)束,兩個進程相互等待,最終導致死鎖。

3. 死鎖問題解決

基于上述分析,只要主進程在waitfor之前,能不斷處理緩沖區(qū)中的數(shù)據(jù)就可以。因為,我們可以再waitfor之前,單獨啟兩個額外的線程,分別用于處理InputStream和ErrorStream就可以

try {
            //獲取進程的標準輸入流
            final InputStream is1 = process.getInputStream();
            //獲取進城的錯誤流
            final InputStream is2 = process.getErrorStream();
            //啟動兩個線程,一個線程負責讀標準輸出流,另一個負責讀標準錯誤流
            new Thread() {
                public void run() {
                    BufferedReader br1 = new BufferedReader(new InputStreamReader(is1));
                    try {
                        String line1 = null;
                        while ((line1 = br1.readLine()) != null) {
                            if (line1 != null){}
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    finally{
                        try {
                            is1.close();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }.start();

            new Thread() {
                public void  run() {
                    BufferedReader br2 = new  BufferedReader(new  InputStreamReader(is2));
                    try {
                        String line2 = null ;
                        while ((line2 = br2.readLine()) !=  null ) {
                            if (line2 != null){}
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    finally{
                        try {
                            is2.close();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }.start();

            //可能導致進程阻塞,甚至死鎖
            int ret = process.waitFor();
            System.out.println("return value:"+ret);
            System.out.println(process.exitValue());
            logger.info("event:{}", "RunExeForWindows",process.exitValue());
            byte[] bytes = new byte[process.getInputStream().available()];
            process.getInputStream().read(bytes);
            System.out.println(new String(bytes));
            logger.info("event:{}", "RunExeForWindows",new String(bytes));
        }catch (Exception ex){
            ex.printStackTrace();
            try{
                process.getErrorStream().close();
                process.getInputStream().close();
                process.getOutputStream().close();
            }
            catch(Exception ee){}
        }

如此便可以將 waitfor死鎖問題避開,看完這個問題,總結(jié)一下,多看官方api注釋….其實官方已經(jīng)提示我們,如下 為 api注釋

Causes the current thread to wait, if necessary, until the
     * process represented by this {@code Process} object has
     * terminated.  This method returns immediately if the subprocess
     * has already terminated.  If the subprocess has not yet
     * terminated, the calling thread will be blocked until the
     * subprocess exits.
@return the exit value of the subprocess represented by this
     *         {@code Process} object.  By convention, the value
     *         {@code 0} indicates normal termination.
     * @throws InterruptedException if the current thread is
     *         {@linkplain Thread#interrupt() interrupted} by another
     *         thread while it is waiting, then the wait is ended and
     *         an {@link InterruptedException} is thrown.

如果需要,導致當前線程等待,直到此{@code Process}對象表示的進程具有終止 如果子進程,此方法立即返回已經(jīng)終止。 如果子進程還沒有終止后,調(diào)用線程將被阻塞,直到子進程退出。

總結(jié)

到此這篇關(guān)于java使用Process調(diào)用exe程序及Process.waitFor()死鎖問題解決的文章就介紹到這了,更多相關(guān)java用Process調(diào)用exe程序內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • SpringBoot結(jié)合Redis配置工具類實現(xiàn)動態(tài)切換庫

    SpringBoot結(jié)合Redis配置工具類實現(xiàn)動態(tài)切換庫

    本文主要介紹了SpringBoot結(jié)合Redis配置工具類實現(xiàn)動態(tài)切換庫,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2022-08-08
  • java Hibernate save()與persist()區(qū)別

    java Hibernate save()與persist()區(qū)別

    本文章來給各位同學介紹一下Hibernate save()與persist()區(qū)別,希望此文章能對各位同學對于Hibernate save()與persist()有所理解
    2016-01-01
  • 解決Eclipse配置Tomcat出現(xiàn)Cannot create a server using the selected type錯誤

    解決Eclipse配置Tomcat出現(xiàn)Cannot create a server using the selected

    這篇文章主要介紹了解決Eclipse配置Tomcat出現(xiàn)Cannot create a server using the selected type錯誤的相關(guān)資料,需要的朋友可以參考下
    2017-02-02
  • IntelliJ中高效重構(gòu)的10個快捷方式詳解

    IntelliJ中高效重構(gòu)的10個快捷方式詳解

    這篇文章主要為大家介紹了IntelliJ中高效重構(gòu)的10個快捷方式詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-01-01
  • 最新評論