快捷導(dǎo)航

java?線程池存在的意義

更新時(shí)間：2022年06月15日 08:30:12 作者：??zxhtom????

這篇文章主要介紹了java線程池存在的意義,通過(guò)多線程案例模擬鎖的產(chǎn)生的情況展開(kāi)對(duì)主題的詳細(xì)介紹，具有一定的參考價(jià)值，需要的朋友可以參考一下

前言

再次之前我已經(jīng)花費(fèi)大量篇幅介紹了Java原聲鎖和Lock鎖。在文章中提到偏向送、輕量級(jí)鎖、重量級(jí)鎖、公平鎖、非公平鎖、自旋鎖、自適應(yīng)自旋鎖、分布式鎖、分段鎖等等鎖。所有的鎖都是為了解決一個(gè)問(wèn)題應(yīng)運(yùn)而生的那就是并發(fā)。而產(chǎn)生并發(fā)的原因是CPU的發(fā)展導(dǎo)致我們程序多線程運(yùn)行。在代碼中我們也經(jīng)常通過(guò)多線程來(lái)提高產(chǎn)品的吞吐量。

在鎖章節(jié)中我們也是通過(guò)多線程案例模擬鎖的產(chǎn)生的。那么Java領(lǐng)域中有哪幾種方式生成線程呢？容我慢慢道來(lái)

創(chuàng)建線程

繼承Thread

創(chuàng)建線程的方式Java為我們提供了四種方式，首先是繼承Thread 。復(fù)寫(xiě)run方法就可以了。

?public class ExtendThread extends Thread{
? ? ?private Integer index;
??
? ? ?public ExtendThread(Integer index) {
? ? ? ? ?this.index = index;
? ?  }
? ? ?@Override
? ? ?public void run() {
? ? ? ? ?System.out.println("當(dāng)前索引值："+index);
? ?  }
??
? ? ?public static void main(String[] args) {
? ? ? ? ?for (int i = 0; i < 100; i++) {
? ? ? ? ? ? ?new ExtendThread(i).start();
? ? ? ?  }
? ?  }
?}

實(shí)現(xiàn)Runnable接口

第二種方式就是實(shí)現(xiàn)Runnable接口。我們點(diǎn)進(jìn)Thread源碼也能看到，thread的構(gòu)造需要一個(gè)Runnable接口。

?public class TestRunnable implements Runnable{
? ? ?private String userName;
??
? ? ?public TestRunnable(String userName) {
? ? ? ? ?this.userName = userName;
? ?  }
? ? ?@SneakyThrows
? ? ?@Override
? ? ?public void run() {
? ? ? ? ?TimeUnit.SECONDS.sleep(1);
? ? ? ? ?System.out.println("當(dāng)前名稱："+userName);
? ?  }
??
? ? ?public static void main(String[] args) {
? ? ? ? ?for (int i = 0; i < 100; i++) {
? ? ? ? ? ? ?new Thread(new TestRunnable(String.format("我是%s", i))).start();
? ? ? ?  }
? ?  }
?}

實(shí)現(xiàn)Callable接口

除了上面兩種還有一個(gè)接口實(shí)現(xiàn)。還有一個(gè)Callable他和Runnable的區(qū)別在于有返回值

?public class TestCallable implements Callable {
? ? ?private int i;
??
? ? ?public TestCallable(int i) {
? ? ? ? ?this.i = i;
? ?  }
? ? ?@Override
? ? ?public Object call() throws Exception {
? ? ? ? ?System.out.println(Thread.currentThread()+"我是"+i);
? ? ? ? ?return i;
? ?  }
? ? ?public static void main(String[] args) throws ExecutionException, InterruptedException {
? ? ? ? ?final FutureTask futureTask = new FutureTask(new TestCallable(1));
? ? ? ? ?for (int i = 0; i < 100; i++) {
? ? ? ? ? ? ?new Thread(new FutureTask(new TestCallable(i))).start();
? ? ? ?  }
? ? ? ? ?System.out.println(futureTask.get());
? ?  }
?}

線程池

上面三種應(yīng)該算是線程創(chuàng)建的基本方式。為了提高性能減少線程的開(kāi)辟與銷毀，JDK提出了線程池的概念。線程池主要是在線程閑置后進(jìn)行回收防止被JVM銷毀。這樣下次在來(lái)任務(wù)的時(shí)候就可以直接將閑置的線程提供給任務(wù)使用就可以了。線程池的創(chuàng)建默認(rèn)有三種方式。這里我們使用其中一種，至于線程池我們后面會(huì)著重介紹。

?public class TPools {
? ? ?public static void main(String[] args) {
? ? ? ? ?final ExecutorService executorService = Executors.newCachedThreadPool();
? ? ? ? ?for (int i = 0; i < 100; i++) {
??
? ? ? ? ? ? ?int finalI = i;
? ? ? ? ? ? ?executorService.execute(new Runnable() {
? ? ? ? ? ? ? ? ?@Override
? ? ? ? ? ? ? ? ?public void run() {
? ? ? ? ? ? ? ? ? ? ?System.out.println("@@@@@"+ finalI);
? ? ? ? ? ? ? ?  }
? ? ? ? ? ?  });
? ? ? ?  }
? ?  }
?}

小結(jié)

本章節(jié)我們簡(jiǎn)單介紹了四種方式創(chuàng)建線程。使用上沒(méi)有區(qū)別。需要注意Callable接口是具有返回值的。這種方式其實(shí)我們可以用來(lái)確認(rèn)線程是否執(zhí)行了。然后就是線程池方式創(chuàng)建。從線程的角度四種方式創(chuàng)建出來(lái)的線程具有同等性質(zhì)。不同的是線程池會(huì)對(duì)線程進(jìn)行回收管理。關(guān)于他的回收策略JDK給我們提供了不同的默認(rèn)策略。也支持我們自定義線程結(jié)構(gòu)。

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

您可能感興趣的文章: