本篇文章給大家分享的是有關(guān)Java中實(shí)現(xiàn)線程的方式有哪些,小編覺得挺實(shí)用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù),包含不限于成都網(wǎng)站制作、成都網(wǎng)站設(shè)計(jì)、外貿(mào)營銷網(wǎng)站建設(shè)、大興網(wǎng)絡(luò)推廣、成都微信小程序、大興網(wǎng)絡(luò)營銷、大興企業(yè)策劃、大興品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營等,從售前售中售后,我們都將竭誠為您服務(wù),您的肯定,是我們最大的嘉獎(jiǎng);創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供大興建站搭建服務(wù),24小時(shí)服務(wù)熱線:18982081108,官方網(wǎng)址:www.cdcxhl.com
Java中實(shí)現(xiàn)多線程的方式的方式中最核心的就是 run()
方法,不管何種方式其最終都是通過run()
來運(yùn)行。
Java剛發(fā)布時(shí)也就是JDK 1.0版本提供了兩種實(shí)現(xiàn)方式,一個(gè)是繼承Thread
類,一個(gè)是實(shí)現(xiàn)Runnable
接口。兩種方式都是去重寫run()
方法,在run()
方法中去實(shí)現(xiàn)具體的業(yè)務(wù)代碼。
但這兩種方式有一個(gè)共同的弊端,就是由于run()
方法是沒有返回值的,所以通過這兩方式實(shí)現(xiàn)的多線程讀無法獲得執(zhí)行的結(jié)果。
為了解決這個(gè)問題在JDK 1.5的時(shí)候引入一個(gè)Callable
接口,根據(jù)泛型V
設(shè)定返回值的類型,實(shí)現(xiàn)他的call()
方法,可以獲得線程執(zhí)行的返回結(jié)果。
雖然call()
方法可以獲得返回值,但它需要配合一個(gè)Future
才能拿到返回結(jié)果,而這個(gè)Future
又是繼承了Runnable
的一個(gè)接口。通過查閱源碼就可以發(fā)現(xiàn)Future
的實(shí)現(xiàn)FutureTask
其在做具體業(yè)務(wù)代碼執(zhí)行的時(shí)候仍是在run()
里面實(shí)現(xiàn)的。
public void run() {
if (state != NEW ||
!UNSAFE.compareAndSwapObject(this, runnerOffset,
null, Thread.currentThread()))
return;
try {
Callable c = callable;
if (c != null && state == NEW) {
V result;
boolean ran;
try {
result = c.call();
ran = true;
} catch (Throwable ex) {
result = null;
ran = false;
setException(ex);
}
if (ran)
set(result);
}
} finally {
// runner must be non-null until state is settled to
// prevent concurrent calls to run()
runner = null;
// state must be re-read after nulling runner to prevent
// leaked interrupts
int s = state;
if (s >= INTERRUPTING)
handlePossibleCancellationInterrupt(s);
}
}
public class ThreadTest {
public static void main(String[] args) throws Exception {
Thread myThread = new MyThread();
myThread.setName("MyThread-entends-Thread-test");
myThread.start();
}
}
class MyThread extends Thread {
@Override
public void run() {
System.out.println("Thread Name:" + Thread.currentThread().getName());
}
}
public class ThreadTest {
public static void main(String[] args) throws Exception {
MyRunnableThread myRunnable = new MyRunnableThread();
Thread myRunnableThread = new Thread(myRunnable);
myRunnableThread.setName("MyThread-implements-Runnable-test");
myRunnableThread.start();
}
}
class MyRunnableThread implements Runnable {
@Override
public void run() {
System.out.println("Thread Name:" + Thread.currentThread().getName());
}
}
public class ThreadTest {
public static void main(String[] args) throws Exception {
Callable myCallable = new MyCallableThread();
FutureTask futureTask = new FutureTask<>(myCallable);
Thread myCallableThread = new Thread(futureTask);
myCallableThread.setName("MyThread-implements-Callable-test");
myCallableThread.start();
System.out.println("Run by Thread:" + futureTask.get());
//通過線程池執(zhí)行
ExecutorService executorService = Executors.newCachedThreadPool();
executorService.submit(futureTask);
executorService.shutdown();
System.out.println("Run by ExecutorService:" + futureTask.get());
}
}
class MyCallableThread implements Callable {
@Override
public String call() throws Exception {
return Thread.currentThread().getName();
}
}
以上就是Java中實(shí)現(xiàn)線程的方式有哪些,小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘9ぷ鲿?huì)見到或用到的。希望你能通過這篇文章學(xué)到更多知識(shí)。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。