(1)創(chuàng)建線程有哪幾種方式?
創(chuàng)新互聯(lián)專注于企業(yè)成都全網(wǎng)營銷推廣、網(wǎng)站重做改版、溫宿網(wǎng)站定制設(shè)計、自適應(yīng)品牌網(wǎng)站建設(shè)、H5網(wǎng)站設(shè)計、成都商城網(wǎng)站開發(fā)、集團公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)公司、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計等建站業(yè)務(wù),價格優(yōu)惠性價比高,為溫宿等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。
(2)它們分別有什么運用場景?
創(chuàng)建線程,是多線程編程中最基本的操作,彤哥總結(jié)了一下,大概有8種創(chuàng)建線程的方式,你知道嗎?
public class CreatingThread01 extends Thread {
@Override
public void run() {
System.out.println(getName() + " is running");
}
public static void main(String[] args) {
new CreatingThread01().start();
new CreatingThread01().start();
new CreatingThread01().start();
new CreatingThread01().start();
}
}
繼承Thread類并重寫run()方法,這種方式的弊端是一個類只能繼承一個父類,如果這個類本身已經(jīng)繼承了其它類,就不能使用這種方式了。
public class CreatingThread02 implements Runnable {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " is running");
}
public static void main(String[] args) {
new Thread(new CreatingThread02()).start();
new Thread(new CreatingThread02()).start();
new Thread(new CreatingThread02()).start();
new Thread(new CreatingThread02()).start();
}
}
實現(xiàn)Runnable接口,這種方式的好處是一個類可以實現(xiàn)多個接口,不影響其繼承體系。
public class CreatingThread03 {
public static void main(String[] args) {
// Thread匿名類,重寫Thread的run()方法
new Thread() {
@Override
public void run() {
System.out.println(getName() + " is running");
}
}.start();
// Runnable匿名類,實現(xiàn)其run()方法
new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " is running");
}
}).start();
// 同上,使用lambda表達式函數(shù)式編程,本文由公從號“彤哥讀源碼”原創(chuàng)
new Thread(()->{
System.out.println(Thread.currentThread().getName() + " is running");
}).start();
}
}
使用匿名類的方式,一是重寫Thread的run()方法,二是傳入Runnable的匿名類,三是使用lambda方式,現(xiàn)在一般使用第三種(java8+),簡單快捷。
public class CreatingThread04 implements Callable {
@Override
public Long call() throws Exception {
Thread.sleep(2000);
System.out.println(Thread.currentThread().getId() + " is running");
return Thread.currentThread().getId();
}
public static void main(String[] args) throws ExecutionException, InterruptedException {
FutureTask task = new FutureTask<>(new CreatingThread04());
new Thread(task).start();
System.out.println("等待完成任務(wù)");
Long result = task.get();
System.out.println("任務(wù)結(jié)果:" + result);
}
}
實現(xiàn)Callabe接口,可以獲取線程執(zhí)行的結(jié)果,F(xiàn)utureTask實際上實現(xiàn)了Runnable接口。
public class CreatingThread05 {
public static void main(String[] args) {
Timer timer = new Timer();
// 每隔1秒執(zhí)行一次
timer.schedule(new TimerTask() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " is running");
}
}, 0 , 1000);
}
}
使用定時器java.util.Timer可以快速地實現(xiàn)定時任務(wù),TimerTask實際上實現(xiàn)了Runnable接口。
public class CreatingThread06 {
public static void main(String[] args) {
ExecutorService threadPool = Executors.newFixedThreadPool(5);
for (int i = 0; i < 100; i++) {
threadPool.execute(()-> System.out.println(Thread.currentThread().getName() + " is running"));
}
}
}
使用線程池的方式,可以復(fù)用線程,節(jié)約系統(tǒng)資源。
public class CreatingThread07 {
public static void main(String[] args) {
List list = Arrays.asList(1, 2, 3, 4, 5);
// 串行,打印結(jié)果為12345,本文由公從號“彤哥讀源碼”原創(chuàng)
list.stream().forEach(System.out::print);
System.out.println();
// 并行,打印結(jié)果隨機,比如35214
list.parallelStream().forEach(System.out::print);
}
}
使用并行計算的方式,可以提高程序運行的效率,多線程并行執(zhí)行。
首先,springboot啟動類加上@EnableAsync
注解(@EnableAsync是spring支持的,這里方便舉例使用springboot)。
@SpringBootApplication
@EnableAsync
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
其次,方法加上@Async
注解。
@Service
public class CreatingThread08Service {
@Async
public void call() {
System.out.println(Thread.currentThread().getName() + " is running");
}
}
然后,測試用例直接跟使用一般的Service方法一模一樣。
@RunWith(SpringRunner.class)
@SpringBootTest(classes = Application.class)
public class CreatingThread08Test {
@Autowired
private CreatingThread08Service creatingThread08Service;
@Test
public void test() {
creatingThread08Service.call();
creatingThread08Service.call();
creatingThread08Service.call();
creatingThread08Service.call();
}
}
運行結(jié)果如下:
task-3 is running
task-2 is running
task-1 is running
task-4 is running
可以看到每次執(zhí)行方法時使用的線程都不一樣。
使用Spring異步方法的方式,可以說是相當(dāng)?shù)胤奖?,適用于前后邏輯不相關(guān)聯(lián)的適合用異步調(diào)用的一些方法,比如發(fā)送短信的功能。
(1)繼承Thread類并重寫run()方法;
(2)實現(xiàn)Runnable接口;
(3)匿名內(nèi)部類;
(4)實現(xiàn)Callabe接口;
(5)定時器(java.util.Timer);
(6)線程池;
(7)并行計算(Java8+);
(8)Spring異步方法;
上面介紹了那么多創(chuàng)建線程的方式,其實本質(zhì)上就兩種,一種是繼承Thread類并重寫其run()方法,一種是實現(xiàn)Runnable接口的run()方法,那么它們之間到底有什么聯(lián)系呢?
請看下面的例子,同時繼承Thread并實現(xiàn)Runnable接口,應(yīng)該輸出什么呢?
public class CreatingThread09 {
public static void main(String[] args) {
new Thread(()-> {
System.out.println("Runnable: " + Thread.currentThread().getName());
}) {
@Override
public void run() {
System.out.println("Thread: " + getName());
}
}.start();
}
}
說到這里,我們有必要看一下Thread類的源碼:
public class Thread implements Runnable {
// Thread維護了一個Runnable的實例
private Runnable target;
public Thread() {
init(null, null, "Thread-" + nextThreadNum(), 0);
}
public Thread(Runnable target) {
init(null, target, "Thread-" + nextThreadNum(), 0);
}
private void init(ThreadGroup g, Runnable target, String name,
long stackSize, AccessControlContext acc,
boolean inheritThreadLocals) {
// ...
// 構(gòu)造方法傳進來的Runnable會賦值給target
this.target = target;
// ...
}
@Override
public void run() {
// Thread默認(rèn)的run()方法,如果target不為空,會執(zhí)行target的run()方法
if (target != null) {
target.run();
}
}
}
看到這里是不是豁然開朗呢?既然上面的例子同時繼承Thread并實現(xiàn)了Runnable接口,根據(jù)源碼,實際上相當(dāng)于重寫了Thread的run()方法,在Thread的run()方法時實際上跟target都沒有關(guān)系了。
所以,上面的例子輸出結(jié)果為Thread: Thread-0
,只輸出重寫Thread的run()方法中的內(nèi)容。