Java併發編程:如何創建線程?

来源:http://www.cnblogs.com/8hao/archive/2016/03/01/5230085.html
-Advertisement-
Play Games

在前面一篇文章中已經講述了在進程和線程的由來,今天就來講一下在Java中如何創建線程,讓線程去執行一個子任務。下麵先講述一下Java中的應用程式和進程相關的概念知識,然後再闡述如何創建線程以及如何創建進程。下麵是本文的目錄大綱: 一.Java中關於應用程式和進程相關的概念 二.Java中如何創建線程


在前面一篇文章中已經講述了在進程和線程的由來,今天就來講一下在Java中如何創建線程,讓線程去執行一個子任務。下麵先講述一下Java中的應用程式和進程相關的概念知識,然後再闡述如何創建線程以及如何創建進程。下麵是本文的目錄大綱:

一.Java中關於應用程式和進程相關的概念

二.Java中如何創建線程

三.Java中如何創建進程

一.Java中關於應用程式和進程相關的概念

在Java中,一個應用程式對應著一個JVM實例(也有地方稱為JVM進程),一般來說名字預設為java.exe或者javaw.exe(windows下可以通過任務管理器查看)。Java採用的是單線程編程模型,即在我們自己的程式中如果沒有主動創建線程的話,只會創建一個線程,通常稱為主線程。但是要註意,雖然只有一個線程來執行任務,不代表JVM中只有一個線程,JVM實例在創建的時候,同時會創建很多其他的線程(比如垃圾收集器線程)。

由於Java採用的是單線程編程模型,因此在進行UI編程時要註意將耗時的操作放在子線程中進行,以避免阻塞主線程(在UI編程時,主線程即UI線程,用來處理用戶的交互事件)。

二.Java中如何創建線程

在java中如果要創建線程的話,一般有兩種方式:1)繼承Thread類;2)實現Runnable介面。

  1.繼承Thread類

繼承Thread類的話,必須重寫run方法,在run方法中定義需要執行的任務。

1 2 3 4 5 6 7 8 9 10 11 12 class MyThread extends Thread{  private static int num = 0;    public MyThread(){  num++;  }    @Override  public void run() {  System.out.println("主動創建的第"+num+"個線程");  } }

創建好了自己的線程類之後,就可以創建線程對象了,然後通過start()方法去啟動線程。註意,不是調用run()方法啟動線程,run方法中只是定義需要執行的任務,如果調用run方法,即相當於在主線程中執行run方法,跟普通的方法調用沒有任何區別,此時並不會創建一個新的線程來執行定義的任務。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 public class Test {  public static void main(String[] args) {  MyThread thread = new MyThread();  thread.start();  } }   class MyThread extends Thread{  private static int num = 0;    public MyThread(){  num++;  }    @Override  public void run() {  System.out.println("主動創建的第"+num+"個線程");  } }

在上面代碼中,通過調用start()方法,就會創建一個新的線程了。為了分清start()方法調用和run()方法調用的區別,請看下麵一個例子:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 public class Test {  public static void main(String[] args) {  System.out.println("主線程ID:"+Thread.currentThread().getId());  MyThread thread1 = new MyThread("thread1");  thread1.start();  MyThread thread2 = new MyThread("thread2");  thread2.run();  } }   class MyThread extends Thread{  private String name;    public MyThread(String name){  this.name = name;  }    @Override  public void run() {  System.out.println("name:"+name+" 子線程ID:"+Thread.currentThread().getId());  } }

運行結果:

從輸出結果可以得出以下結論:

1)thread1和thread2的線程ID不同,thread2和主線程ID相同,說明通過run方法調用並不會創建新的線程,而是在主線程中直接運行run方法,跟普通的方法調用沒有任何區別;

2)雖然thread1的start方法調用在thread2的run方法前面調用,但是先輸出的是thread2的run方法調用的相關信息,說明新線程創建的過程不會阻塞主線程的後續執行。

2.實現Runnable介面

在Java中創建線程除了繼承Thread類之外,還可以通過實現Runnable介面來實現類似的功能。實現Runnable介面必須重寫其run方法。

下麵是一個例子:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 public class Test {  public static void main(String[] args) {  System.out.println("主線程ID:"+Thread.currentThread().getId());  MyRunnable runnable = new MyRunnable();  Thread thread = new Thread(runnable);  thread.start();  } }   class MyRunnable implements Runnable{    public MyRunnable() {    }    @Override  public void run() {  System.out.println("子線程ID:"+Thread.currentThread().getId());  } }

Runnable的中文意思是“任務”,顧名思義,通過實現Runnable介面,我們定義了一個子任務,然後將子任務交由Thread去執行。註意,這種方式必須將Runnable作為Thread類的參數,然後通過Thread的start方法來創建一個新線程來執行該子任務。如果調用Runnable的run方法的話,是不會創建新線程的,這根普通的方法調用沒有任何區別。

事實上,查看Thread類的實現源代碼會發現Thread類是實現了Runnable介面的。

在Java中,這2種方式都可以用來創建線程去執行子任務,具體選擇哪一種方式要看自己的需求。直接繼承Thread類的話,可能比實現Runnable介面看起來更加簡潔,但是由於Java只允許單繼承,所以如果自定義類需要繼承其他類,則只能選擇實現Runnable介面。

三.Java中如何創建進程

在Java中,可以通過兩種方式來創建進程,總共涉及到5個主要的類。

第一種方式是通過Runtime.exec()方法來創建一個進程,第二種方法是通過ProcessBuilder的start方法來創建進程。下麵就來講一講這2種方式的區別和聯繫。

首先要講的是Process類,Process類是一個抽象類,在它裡面主要有幾個抽象的方法,這個可以通過查看Process類的源代碼得知:

位於java.lang.Process路徑下:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 public abstract class Process {    abstract public OutputStream getOutputStream(); //獲取進程的輸出流    abstract public InputStream getInputStream(); //獲取進程的輸入流    abstract public InputStream getErrorStream(); //獲取進程的錯誤流    abstract public int waitFor() throws InterruptedException; //讓進程等待    abstract public int exitValue(); //獲取進程的退出標誌    abstract public void destroy(); //摧毀進程 }

 1)通過ProcessBuilder創建進程

ProcessBuilder是一個final類,它有兩個構造器:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 public final class ProcessBuilder {  private List<String> command;  private File directory;  private Map<String,String> environment;  private boolean redirectErrorStream;    public ProcessBuilder(List<String> command) {  if (command == null)  throw new NullPointerException();  this.command = command;  }    public ProcessBuilder(String... command) {  this.command = new ArrayList<String>(command.length);  for (String arg : command)  this.command.add(arg);  } .... }

構造器中傳遞的是需要創建的進程的命令參數,第一個構造器是將命令參數放進List當中傳進去,第二構造器是以不定長字元串的形式傳進去。

那麼我們接著往下看,前面提到是通過ProcessBuilder的start方法來創建一個新進程的,我們看一下start方法中具體做了哪些事情。下麵是start方法的具體實現源代碼:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 public Process start() throws IOException { // Must convert to array first -- a malicious user-supplied // list might try to circumvent the security check. String[] cmdarray = command.toArray(new String[command.size()]); for (String arg : cmdarray)  if (arg == null)  throw new NullPointerException(); // Throws IndexOutOfBoundsException if command is empty String prog = cmdarray[0];   SecurityManager security = System.getSecurityManager(); if (security != null)  security.checkExec(prog);   String dir = directory == null ? null : directory.toString();   try {  return ProcessImpl.start(cmdarray,  environment,  dir,  redirectErrorStream); } catch (IOException e) {  // It's much easier for us to create a high-quality error  // message than the low-level C code which found the problem.  throw new IOException(  "Cannot run program \"" + prog + "\""  + (dir == null ? "" : " (in directory \"" + dir + "\")")  + ": " + e.getMessage(),  e); } }

該方法返回一個Process對象,該方法的前面部分相當於是根據命令參數以及設置的工作目錄進行一些參數設定,最重要的是try語句塊裡面的一句:

1 2 3 4 return ProcessImpl.start(cmdarray,  environment,  dir,  redirectErrorStream);

說明真正創建進程的是這一句,註意調用的是ProcessImpl類的start方法,此處可以知道start必然是一個靜態方法。那麼ProcessImpl又是什麼類呢?該類同樣位於java.lang.ProcessImpl路徑下,看一下該類的具體實現:

ProcessImpl也是一個final類,它繼承了Process類:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 final class ProcessImpl extends Process {    // System-dependent portion of ProcessBuilder.start()  static Process start(String cmdarray[],  java.util.Map<String,String> environment,  String dir,  boolean redirectErrorStream)  throws IOException  {  String envblock = ProcessEnvironment.toEnvironmentBlock(environment);  return new ProcessImpl(cmdarray, envblock, dir, redirectErrorStream);  }  .... }

這是ProcessImpl類的start方法的具體實現,而事實上start方法中是通過這句來創建一個ProcessImpl對象的:

1 return new ProcessImpl(cmdarray, envblock, dir, redirectErrorStream);

而在ProcessImpl中對Process類中的幾個抽象方法進行了具體實現。

說明事實上通過ProcessBuilder的start方法創建的是一個ProcessImpl對象。

下麵看一下具體使用ProcessBuilder創建進程的例子,比如我要通過ProcessBuilder來啟動一個進程打開cmd,並獲取ip地址信息,那麼可以這麼寫:

1 2 3 4 5 6 7 8 9 10 11 12 public class Test {  public static void main(String[] args) throws IOException {  ProcessBuilder pb = new ProcessBuilder("cmd","/c","ipconfig/all");  Process process = pb.start();  Scanner scanner = new Scanner(process.getInputStream());    while(scanner.hasNextLine()){  System.out.println(scanner.nextLine());  }  scanner.close();  } }

第一步是最關鍵的,就是將命令字元串傳給ProcessBuilder的構造器,一般來說,是把字元串中的每個獨立的命令作為一個單獨的參數,不過也可以按照順序放入List中傳進去。

至於其他很多具體的用法不在此進行贅述,比如通過ProcessBuilder的environment方法和directory(File directory)設置進程的環境變數以及工作目錄等,感興趣的朋友可以查看相關API文檔。

  2)通過Runtime的exec方法來創建進程

首先還是來看一下Runtime類和exec方法的具體實現,Runtime,顧名思義,即運行時,表示當前進程所在的虛擬機實例。

由於任何進程只會運行於一個虛擬機實例當中,所以在Runtime中採用了單例模式,即只會產生一個虛擬機實例:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 public class Runtime {  private static Runtime currentRuntime = new Runtime();    /**  * Returns the runtime object associated with the current Java application.  * Most of the methods of class <code>Runtime</code> are instance  * methods and must be invoked with respect to the current runtime object.  *  * @return the <code>Runtime</code> object associated with the current  * Java application.  */  public static Runtime getRuntime() {  return currentRuntime;  }    /** Don't let anyone else instantiate this class */  private Runtime() {}  ...  }

從這裡可以看出,由於Runtime類的構造器是private的,所以只有通過getRuntime去獲取Runtime的實例。接下來著重看一下exec方法 實現,在Runtime中有多個exec的不同重載實現,但真正最後執行的是這個版本的exec方法:

1 2 3 4 5 6 7 public Process exec(String[] cmdarray, String[] envp, File dir)  throws IOException {  return new ProcessBuilder(cmdarray)  .environment(envp)  .directory(dir)  .start();  }

可以發現,事實上通過Runtime類的exec創建進程的話,最終還是通過ProcessBuilder類的start方法來創建的。

下麵看一個例子,看一下通過Runtime的exec如何創建進程,還是前面的例子,調用cmd,獲取ip地址信息:

1 2 3 4 5 6 7 8 9 10 11 12 public class Test {  public static void main(String[] args) throws IOException {  String cmd = "cmd "+"/c "+"ipconfig/all";  Process process = Runtime.getRuntime().exec(cmd);  Scanner scanner = new Scanner(process.getInputStream());    while(scanner.hasNextLine()){  System.out.println(scanner.nextLine());  }  scanner.close();  } }

要註意的是,exec方法不支持不定長參數(ProcessBuilder是支持不定長參數的),所以必須先把命令參數拼接好再傳進去。

關於在Java中如何創建線程和進程的話,暫時就講這麼多了,感興趣的朋友可以參考相關資料、

參考資料:

http://luckykapok918.blog.163.com/blog/static/205865043201210272168556/

http://www.cnblogs.com/ChrisWang/archive/2009/12/02/use-java-lang-process-and-processbuilder-to-create-native-application-process.html

http://lavasoft.blog.51cto.com/62575/15662/

問啊-一鍵呼叫程式員答題神器,牛人一對一服務,開發者編程必備官方網站:www.wenaaa.com

QQ群290551701 聚集很多互聯網精英,技術總監,架構師,項目經理!開源技術研究,歡迎業內人士,大牛及新手有志於從事IT行業人員進入!


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Jetty是一個用 Java 實現、開源、基於標準的,並且具有豐富功能的 Http 伺服器和 Web 容器。Jetty中應用最廣泛的一項功能就是可以作為嵌入式Web容器。 在開發階段,可以使用Jetty在Eclipse里直接啟動應用,而不是像Tomcat那樣繁瑣,先把幾十兆應用打包,然後再複製到某個
  • 因為公司項目線上人數的增加,隨著現在硬體成本越來越低,大多數的生產環境記憶體大多都已經達到 16G,尤其最新的阿裡雲,客戶的機器都是配置超高的java主機,但是Java的運行環境,記憶體使用有限 ,這樣就造成了這台伺服器資源的浪費,所以單機的多Tomcat集群就很有必要!當然有客戶有多台伺服器,這樣更好
  • 首先純html頁要用meta標簽聲明編碼<meta http-equiv="Content-Type" content="text/html; charset="utf-8" />有php輸出的頁要使用header函數聲明編碼header("Content-Type:text/html; chars
  • 相信String這個類是Java中使用得最頻繁的類之一,並且又是各大公司面試喜歡問到的地方,今天就來和大家一起學習一下String、StringBuilder和StringBuffer這幾個類,分析它們的異同點以及瞭解各個類適用的場景。下麵是本文的目錄大綱: 一.你瞭解String類嗎? 二.深入理
  • 語法 它通過{}和:來代替%。“映射”示例 通過位置 In [1]: '{0},{1}'.format('kzc',18) Out[1]: 'kzc,18' In [2]: '{},{}'.format('kzc',18) Out[2]: 'kzc,18' In [3]: '{1},{0},{1}'
  • excel表格上傳和下載,斷斷續續寫了很久,趕緊記下來萬一以後忘記就虧大了= = 資料庫有三張表: 上傳一張表格,每個sheet對應一個if_table_n,if_user_table記錄上傳信息,if_column_map記錄每個if_table_n的列名與資料庫列名對應,if_system_co
  • 一、網路編程中的重要的類 1、InetAddress:互聯網協議(IP)地址 封裝電腦的IP地址和DNS(功能變數名稱解析),沒有埠,構造器私有化。通過相關方法得到。 例如: public class InetDemo01 { public static void main(String[] args)
  • web應用程式基本上都是在瀏覽器地址欄輸入一段網站,然後進入,最後瀏覽器顯示你想要的東西。 這就是用戶所能體會到的東西。那作為程式員我們看到了什麼呢? 一次HTTP 請求主要的流程是: 1、DNS伺服器解析功能變數名稱(瀏覽器地址欄的地址)獲取相應的IP地址、埠號、 服務名。 2、客戶端根據解析後的地址向
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...