快捷導(dǎo)航

淺談一下Java的線程并發(fā)

更新時(shí)間：2022年02月08日 14:45:01 作者：ldcaws

大家好，本篇文章主要講的是淺談一下Java的線程并發(fā)，感興趣的同學(xué)趕快來看一看吧，對(duì)你有幫助的話記得收藏一下

談到并發(fā)，必會(huì)涉及操作系統(tǒng)中的線程概念，線程是CPU分配的最小單位，windows系統(tǒng)是搶占式的，linux是輪詢式的，都需要獲取CPU資源。
并行：同一時(shí)刻，兩個(gè)線程都在執(zhí)行。
并發(fā)：同一時(shí)刻，只有一個(gè)線程執(zhí)行，但是一個(gè)時(shí)間段內(nèi)，兩個(gè)線程都執(zhí)行了。
java中創(chuàng)建線程的三種方式，分別為集成Thread類、實(shí)現(xiàn)Runnable接口，實(shí)現(xiàn)Callable接口。

在這里插入圖片描述

示例

public class ThreadTest {

    public static class MyThread extends Thread {

        @Override
        public void run() {
            System.out.println("This is a thread");
        }
    }

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

public class RunnableTest implements Runnable {

    @Override
    public void run() {
        System.out.println("Runnable!");
    }

    public static void main(String[] args) {
        RunnableTest runnableTest = new RunnableTest();
        new Thread(runnableTest).start();
    }
}

public class CallableTest implements Callable<String> {

    @Override
    public String call() throws Exception {
        return "Callable!";
    }

    public static void main(String[] args) {
        FutureTask<String> futureTask = new FutureTask<>(new CallableTest());
        new Thread(futureTask).start();
        try {
            String result = futureTask.get();
            System.out.println(result);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

CountDownLatch理解成倒計(jì)數(shù)器
場(chǎng)景：玩的王者榮耀，創(chuàng)建大喬、蘭陵王、安其拉、哪吒和鎧等五個(gè)玩家，主線程必須在他們都完成確認(rèn)后，才可以繼續(xù)運(yùn)行。

public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(5);

        Thread DaQiao = new Thread(countDownLatch::countDown);
        Thread LanLingWang = new Thread(countDownLatch::countDown);
        Thread AnQiLa = new Thread(countDownLatch::countDown);
        Thread NeZha = new Thread(countDownLatch::countDown);
        Thread Kai = new Thread(() -> {
            try {
                // 稍等，上個(gè)衛(wèi)生間，馬上到...
                Thread.sleep(1500);
                countDownLatch.countDown();
            } catch (InterruptedException ignored) {}
        });

        DaQiao.start();
        LanLingWang.start();
        AnQiLa.start();
        NeZha.start();
        Kai.start();
        countDownLatch.await();
        System.out.println("所有玩家已經(jīng)就位！");
    }

CyclicBarrier可以理解成同步屏障
場(chǎng)景：讓一組線程到達(dá)一個(gè)屏障（也可以叫同步點(diǎn)）時(shí)被阻塞，直到最后一個(gè)線程到達(dá)屏障時(shí)，屏障才會(huì)開門，所有被屏障攔截的線程才會(huì)繼續(xù)運(yùn)行。

到此這篇關(guān)于淺談一下Java的線程并發(fā)的文章就介紹到這了,更多相關(guān)Java線程并發(fā)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: