多線程Thread、Runnable以及Callable的實現方式

這篇文章主要講解了“多線程Thread、Runnable以及Callable的實現方式”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“多線程Thread、Runnable以及Callable的實現方式”吧！

目錄

• 一、創建線程的常用三種方式

• 1、繼承Thread類

• 2、實現Runnable接口(重點)

• 以多個線程并發，解決方法為例

• 3、 實現Callable接口（JDK1.5版本之后引入的）

一、創建線程的常用三種方式

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 th2=new Thread(bf,"售票窗口1");
         Thread th3=new Thread(bf,"售票窗口2");
         Thread th4=new Thread(bf,"售票窗口3");
         Thread th5=new Thread(bf,"售票窗口4");
         th2.start();
         th3.start();
         th4.start();
         th5.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、Runnable以及Callable的實現方式”的內容了，經過本文的學習后，相信大家對多線程Thread、Runnable以及Callable的實現方式這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！