多線程Thread,Runnable,Callable實現方式
一、創建線程的常用三種方式
1、繼承Thread類
創建MyThread 類並繼承Thread
package com.zrrd.XianCheng; /** *繼承Thread類,達到線程的能力 */ public class MyThread extends Thread{ private String name; public MyThread(String name){ this.name=name; } @Override public void run() { for(int i=0;i<=100;i++){ System.out.println(name+"下載瞭"+i+"%"); } } }
創建測試類ThreadText 啟動線程,執行代碼塊
package com.zrrd.XianCheng; /** * 測試線程代碼 */ public class ThreadText { public static void main(String[] args) { //創建一個線程對象 MyThread my=new MyThread( "A線程"); //啟動線程start() my.start(); //創建第二個線程對象 MyThread my1=new MyThread("B線程"); //啟動線程start() my1.start(); } }
執行結果圖片,截取部分結果集
2、實現Runnable接口(重點)
以多個線程並發,解決方法為例
**創建BingFa 類並實現Runnable **
package com.zrrd.XianCheng; /** * 多個線程並發,解決方法 */ public class BingFa implements Runnable { int piaoshu=50; Object obj=new Object(); @Override public void run() { /* 同步代碼塊用synchronized修飾*/ while (true){ synchronized (obj){//發生阻塞事件 if(piaoshu>0){ System.out.println(Thread.currentThread().getName()+"剩餘"+(piaoshu--)+"張"); }else{ break; } } try { Thread.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println(Thread.currentThread().getName()+"結束售票"); } }
創建測試類BingFaText啟動線程,執行代碼塊
package com.zrrd.XianCheng; import java.lang.Thread; public class BingFaText { public static void main(String[] args) { BingFa bf=new BingFa(); Thread th1=new Thread(bf,"售票窗口1"); Thread th2=new Thread(bf,"售票窗口2"); Thread th3=new Thread(bf,"售票窗口3"); Thread th4=new Thread(bf,"售票窗口4"); th1.start(); th2.start(); th3.start(); th4.start(); } }
執行結果圖片,截取部分結果集
3、 實現Callable接口(JDK1.5版本之後引入的)
創建MyCallable類並實現Callable<T>
package com.zrrd.XianCheng; import java.util.concurrent.Callable; public class MyCallable implements Callable<String> {//多線程主體類 private int ticket=5; //線程共享資源 @Override public String call() throws Exception { for (int i=0;i<100;i++){ if(this.ticket>0){ System.out.println("賣票,ticket="+this.ticket--); } } return "票已賣光!"; //返回結果 } }
創建測試類MyCallableDemo啟動線程,執行代碼塊
package com.zrrd.XianCheng; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; public class MyCallableDemo { public static void main(String[] args) throws ExecutionException, InterruptedException { MyCallable callable1 = new MyCallable();//創建多線程實例1 MyCallable callable2 = new MyCallable();//創建多線程實例2 FutureTask task1 = new FutureTask<String>(callable1); FutureTask task2 = new FutureTask<String>(callable2); //FutureTask 是Runnable接口的子類,所以可以使用Thread類的構造方法來接收task對象 new Thread(task1).start(); new Thread(task2).start(); System.out.println("A______"+task1.get()); System.out.println("B______"+task2.get()); } }
執行結果圖片
總結
以上就是實現多線程的方式,在實際開發項目中不建議使用第一種繼承Thread方式實現線程,這樣對代碼的侵入性太高,而且類與類之間單繼承,達不到代碼重用規則,建議使用第二種、或第三種。
本篇文章就到這裡瞭,希望能給你帶來幫助,也希望您能夠多多關註WalkonNet的更多內容!
推薦閱讀:
- Java詳解實現多線程的四種方式總結
- Java使用Runnable和Callable實現多線程的區別詳解
- Java基礎之多線程的三種實現方式
- Java並發教程之Callable和Future接口詳解
- 新手瞭解java 多線程基礎知識