java創(chuàng)建線程的四種方式

Java使用Thread類代表線程,所有線程都是Thread類或其子類哩照,Java創(chuàng)建線程的方式有4種,它們分別是:
1椰棘、繼承Thread類創(chuàng)建線程纺棺;
2、實現Runable接口創(chuàng)建線程(首推)邪狞;
3祷蝌、使用Callable和Future創(chuàng)建線程;
4帆卓、使用線程池巨朦,例如Executor框架。

注意:call()方法有返回值鳞疲,run()方法沒有罪郊。

方式1:Thread

public class MyThread extends Thread {

    public void run(){
        System.out.println("線程");
    }
}

public class MainTest {

    public static void main(String[] args){
        new MyThread().start();
    }
}

方式2:Runnable

public class MyThread implements Runnable {

    public void run(){
        System.out.println("線程Runnable");
    }
}

public class MainTest {

    public static void main(String[] args){
        MyThread myThread = new MyThread();
        Thread thread = new Thread(myThread);
        thread.start();
    }
}

或者直接寫線程的實現

public class MainTest {

    public static void main(String[] args){
       
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("創(chuàng)建線程方式二");
            }
        }).start();
    }
}

方式3:Callable或者Future

public class CallableTest implements Callable<Integer> {

    @Override
    public Integer call() throws Exception {
        // 計算1-100的和
        int sum = 0;

        for (int i = 1; i <= 100; i++)
            sum += i;

        return sum;
    }

}

public class MainTest {

    public static void main(String[] args) {
        CallableTest cd = new CallableTest();
        // 使用Callable方式創(chuàng)建線程,需要FutureTask類的支持尚洽,用于接收運算結果悔橄,可以使用泛型指定返回值的類型
        FutureTask<Integer> result = new FutureTask<>(cd);
        new Thread(result).start();
        int sum = 0;
        // 接收運算結果
        // 只有當該線程執(zhí)行完畢后才會獲取到運算結果,等同于閉鎖的效果
        try {
            sum = result.get();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        System.out.println("sum is " + sum);
    }
}

方式4:Executor框架

Executor框架包括:線程池腺毫,Executor癣疟,Executors,ExecutorService潮酒,CompletionService睛挚,Future,Callable等
ExecutorService的生命周期包括三種狀態(tài):運行急黎、關閉扎狱、終止。創(chuàng)建后便進入運行狀態(tài)勃教,當調用了shutdown()方法時淤击,便進入關閉狀態(tài),此時意味著ExecutorService不再接受新的任務故源,但它還在執(zhí)行已經提交了的任務污抬,當素有已經提交了的任務執(zhí)行完后,便到達終止狀態(tài)绳军。

Executors提供了一系列工廠方法用于創(chuàng)建線程池印机,返回的線程池都實現了ExecutorService接口
1、創(chuàng)建固定數目線程的線程池

public static ExecutorService newFixedThreadPool(int nThreads)

2门驾、創(chuàng)建可緩存的線程池

public static ExecutorService newCachedThreadPool()

3射赛、創(chuàng)建一個單線程化的Executor

public static ExecutorService newSingleThreadExecutor()

4、創(chuàng)建一個支持定時及周期性的任務執(zhí)行的線程池奶是,多數情況下可用來替代Timer類

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

Executor執(zhí)行Runable任務示例:

public class MainTest {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
//      ExecutorService executorService = Executors.newFixedThreadPool(5);
//      ExecutorService executorService = Executors.newSingleThreadExecutor();
            for (int i = 0; i < 5; i++){
                executorService.execute(new TestRunnable());
                System.out.println("************* a" + i + " *************");
            }
            executorService.shutdown();
        }
    }

    class TestRunnable implements Runnable{
        public void run(){
            System.out.println(Thread.currentThread().getName() + "線程被調用了咒劲。");
        }
    }
public class MainTest {

    private ExecutorService pool;

    @PostConstruct
    public void init(){
        //自定義線程工廠
        pool = new ThreadPoolExecutor(5, 10, 1000, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(20),
                new ThreadFactory() {
                    @Override
                    public Thread newThread(Runnable r) {
                        //線程命名
                        Thread th = new Thread(r,"threadPool"+r.hashCode());
                        return th;
                    }
                },new ThreadPoolExecutor.CallerRunsPolicy());

    }

    public void test(){
        pool.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName() + "線程被調用了顷蟆。");
            }
        });
    }
    
}

Executor實現Callable任務示例:

public class MainTest {

    public static void main(String[] args){
        ExecutorService executorService = Executors.newCachedThreadPool();
        List<Future<String>> resultList = new ArrayList<Future<String>>();

        //創(chuàng)建10個任務并執(zhí)行
        for (int i = 0; i < 10; i++){
            //使用ExecutorService執(zhí)行Callable類型的任務,并將結果保存在future變量中
            Future<String> future = executorService.submit(new TaskWithResult(i));
            //將任務執(zhí)行結果存儲到List中
            resultList.add(future);
        }

        //遍歷任務的結果
        for (Future<String> fs : resultList){
            try{
                while(!fs.isDone());//Future返回如果沒有完成腐魂,則一直循環(huán)等待,直到Future返回完成
                System.out.println(fs.get());     //打印各個線程(任務)執(zhí)行的結果
            }catch(InterruptedException e){
                e.printStackTrace();
            }catch(ExecutionException e){
                e.printStackTrace();
            }finally{
                //啟動一次順序關閉逐纬,執(zhí)行以前提交的任務蛔屹,但不接受新任務
                executorService.shutdown();
            }
        }
    }
    }

class TaskWithResult implements Callable<String>{
    private int id;

    public TaskWithResult(int id){
        this.id = id;
    }

    /**
     * 任務的具體過程,一旦任務傳給ExecutorService的submit方法豁生,
     * 則該方法自動在一個線程上執(zhí)行
     */
    public String call() throws Exception {
        System.out.println("call()方法被自動調用M枚尽!甸箱!    " + Thread.currentThread().getName());
        //該返回結果將被Future的get方法得到
        return "call()方法被自動調用育叁,任務返回的結果是:" + id + "    " + Thread.currentThread().getName();
    }
} 

自定義線程池

自定義線程池,可以用ThreadPoolExecutor類創(chuàng)建芍殖,它有多個構造方法來創(chuàng)建線程池豪嗽,用該類很容易實現自定義的線程池

public class MainTest {

    public static void main(String[] args){
        //創(chuàng)建等待隊列
        BlockingQueue<Runnable> bqueue = new ArrayBlockingQueue<Runnable>(20);
        //創(chuàng)建線程池,池中保存的線程數為3豌骏,允許的最大線程數為5
        ThreadPoolExecutor pool = new ThreadPoolExecutor(3,5,50,TimeUnit.MILLISECONDS,bqueue);
        //創(chuàng)建七個任務
        Runnable t1 = new MyThread1();
        Runnable t2 = new MyThread1();
        Runnable t3 = new MyThread1();
        Runnable t4 = new MyThread1();
        Runnable t5 = new MyThread1();
        Runnable t6 = new MyThread1();
        Runnable t7 = new MyThread1();
        //每個任務會在一個線程上執(zhí)行
        pool.execute(t1);
        pool.execute(t2);
        pool.execute(t3);
        pool.execute(t4);
        pool.execute(t5);
        pool.execute(t6);
        pool.execute(t7);
        //關閉線程池
        pool.shutdown();
    }
    }

class MyThread1 implements Runnable{
    @Override
    public void run(){
        System.out.println(Thread.currentThread().getName() + "正在執(zhí)行龟梦。。窃躲。");
        try{
            Thread.sleep(100);
        }catch(InterruptedException e){
            e.printStackTrace();
        }
    }
}
最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末计贰,一起剝皮案震驚了整個濱河市,隨后出現的幾起案子蒂窒,更是在濱河造成了極大的恐慌躁倒,老刑警劉巖,帶你破解...
    沈念sama閱讀 206,214評論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件洒琢,死亡現場離奇詭異秧秉,居然都是意外死亡,警方通過查閱死者的電腦和手機纬凤,發(fā)現死者居然都...
    沈念sama閱讀 88,307評論 2 382
  • 文/潘曉璐 我一進店門福贞,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人停士,你說我怎么就攤上這事挖帘。” “怎么了恋技?”我有些...
    開封第一講書人閱讀 152,543評論 0 341
  • 文/不壞的土叔 我叫張陵拇舀,是天一觀的道長。 經常有香客問我蜻底,道長骄崩,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 55,221評論 1 279
  • 正文 為了忘掉前任,我火速辦了婚禮要拂,結果婚禮上抠璃,老公的妹妹穿的比我還像新娘。我一直安慰自己脱惰,他們只是感情好搏嗡,可當我...
    茶點故事閱讀 64,224評論 5 371
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著拉一,像睡著了一般采盒。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上蔚润,一...
    開封第一講書人閱讀 49,007評論 1 284
  • 那天磅氨,我揣著相機與錄音,去河邊找鬼嫡纠。 笑死烦租,一個胖子當著我的面吹牛,可吹牛的內容都是我干的货徙。 我是一名探鬼主播左权,決...
    沈念sama閱讀 38,313評論 3 399
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼痴颊!你這毒婦竟也來了赏迟?” 一聲冷哼從身側響起,我...
    開封第一講書人閱讀 36,956評論 0 259
  • 序言:老撾萬榮一對情侶失蹤蠢棱,失蹤者是張志新(化名)和其女友劉穎锌杀,沒想到半個月后,有當地人在樹林里發(fā)現了一具尸體泻仙,經...
    沈念sama閱讀 43,441評論 1 300
  • 正文 獨居荒郊野嶺守林人離奇死亡糕再,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 35,925評論 2 323
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現自己被綠了玉转。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片突想。...
    茶點故事閱讀 38,018評論 1 333
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖究抓,靈堂內的尸體忽然破棺而出猾担,到底是詐尸還是另有隱情,我是刑警寧澤刺下,帶...
    沈念sama閱讀 33,685評論 4 322
  • 正文 年R本政府宣布绑嘹,位于F島的核電站,受9級特大地震影響橘茉,放射性物質發(fā)生泄漏工腋。R本人自食惡果不足惜姨丈,卻給世界環(huán)境...
    茶點故事閱讀 39,234評論 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望擅腰。 院中可真熱鬧蟋恬,春花似錦、人聲如沸惕鼓。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,240評論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽箱歧。三九已至,卻和暖如春一膨,著一層夾襖步出監(jiān)牢的瞬間呀邢,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,464評論 1 261
  • 我被黑心中介騙來泰國打工豹绪, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留价淌,地道東北人。 一個月前我還...
    沈念sama閱讀 45,467評論 2 352
  • 正文 我出身青樓瞒津,卻偏偏與公主長得像蝉衣,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子巷蚪,可洞房花燭夜當晚...
    茶點故事閱讀 42,762評論 2 345