Java中实现线程的方式
Posted coding-diary
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java中实现线程的方式相关的知识,希望对你有一定的参考价值。
Java中实现线程的方式
Java中实现多线程的方式的方式中最核心的就是 run()
方法,不管何种方式其最终都是通过run()
来运行。
Java刚发布时也就是JDK 1.0版本提供了两种实现方式,一个是继承Thread
类,一个是实现Runnable
接口。两种方式都是去重写run()
方法,在run()
方法中去实现具体的业务代码。
但这两种方式有一个共同的弊端,就是由于run()
方法是没有返回值的,所以通过这两方式实现的多线程读无法获得执行的结果。
为了解决这个问题在JDK 1.5的时候引入一个Callable<V>
接口,根据泛型V
设定返回值的类型,实现他的call()
方法,可以获得线程执行的返回结果。
虽然call()
方法可以获得返回值,但它需要配合一个Future<V>
才能拿到返回结果,而这个Future<V>
又是继承了Runnable
的一个接口。 通过查阅源码就可以发现Future<V>
的实现FutureTask<V>
其在做具体业务代码执行的时候仍是在run()
里面实现的。
FutureTask 源码片段:
public void run()
if (state != NEW ||
!UNSAFE.compareAndSwapObject(this, runnerOffset,
null, Thread.currentThread()))
return;
try
Callable<V> 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);
Java多线程实现方式的代码示例:
通过继承Thread类实现
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());
通过实现Runnable接口实现
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());
通过实现Callable接口实现
public class ThreadTest
public static void main(String[] args) throws Exception
Callable<String> myCallable = new MyCallableThread();
FutureTask<String> 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());
//通过线程池执行
ExecutorService executorService = Executors.newCachedThreadPool();
executorService.submit(futureTask);
executorService.shutdown();
System.out.println("Run by ExecutorService:" + futureTask.get());
class MyCallableThread implements Callable<String>
@Override
public String call() throws Exception
return Thread.currentThread().getName();
当然由于线程的创建和销毁需要消耗资源,Java中还通过了许多线程池相关的API,上述示例中ExecutorService
就是线程池API中的一个,关于线程池的详细内容将会在下一篇继续,欢迎大家关注。
以上是关于Java中实现线程的方式的主要内容,如果未能解决你的问题,请参考以下文章