您的位置:首页 > 其它

【多线程 2】常见的多线程创建方式

2016-10-12 20:32 369 查看
导读:创建多线程,主要是有3种方式。而这三种方式,又可以简单的分为:无回执结果、有回执结果。

一、直接继承Thread类

<span style="font-family:KaiTi_GB2312;font-size:18px;">package Angel;

public class CreateThread extends Thread {

//对run方法进行重写
public void run(){
System.out.println("继承Thread创建:" + Thread.currentThread().getName());
System.out.println("继承Thread创建:" + this.getName());
}
public static void main(String[] args) {
new CreateThread().start();
}
}
</span>

二、实现Runnable接口

<span style="font-family:KaiTi_GB2312;font-size:18px;">package Angel;

public class CreateThread implements Runnable {

//对run方法进行重写
public void run(){
System.out.println("实现Runnable接口创建:" + Thread.currentThread().getName());
}
public static void main(String[] args) {

CreateThread newThread=new CreateThread();
new Thread(newThread,"Thread 1").start();
new Thread(newThread,"Thread 2").start();
}
}</span>

备注:在实际应用的时候,通常也可以写作:
<span style="font-family:KaiTi_GB2312;font-size:18px;">package Angel;

public class CreateThread {

/**
* @param args
*/
public static void main(String[] args) {

Thread thread = new Thread() {
@Override
public void run() {
System.out.println("创建Thread对象:" + Thread.currentThread().getName());
System.out.println("创建Thread对象:" + this.getName());
}
};
thread.start();

Thread thread2 = new Thread(new Runnable() {
@Override
public void run() {
System.out.println("创建Runnable对象:" + Thread.currentThread().getName());
}
});
thread2.start();
}
}
</span>

以上的两种方式,是没有回执结果的创建方式,也是常用的创建方式。下面介绍一种可以返回结果的线程的创建方法

三、使用Callable和Future

<pre name="code" class="java"><span style="font-family:KaiTi_GB2312;font-size:18px;">package Angel;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class CreateThread implements Callable<String>
{

public static void main(String[] args)
{
System.out.println("主线程开始");

CreateThread ctt = new CreateThread();
FutureTask<String> ft = new FutureTask<>(ctt);
new Thread(ft,"开始子线程").start();
try
{
System.out.println("子线程的返回值:"+ft.get());
} catch (InterruptedException e)
{
e.printStackTrace();
} catch (ExecutionException e)
{
e.printStackTrace();
}

System.out.println("主线程结束");
}

@Override
public String call() throws Exception
{
System.out.println(Thread.currentThread().getName());
return "successful";
}

} </span>



在应用中的写法:

<span style="font-family:KaiTi_GB2312;font-size:18px;">package Angel;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class CreateThread {

public static void main(String[] args) {
ExecutorService threadPool = Executors.newSingleThreadExecutor();
Future<String> future = threadPool.submit(new Callable<String>() {
public String call() throws Exception {//线程执行结果
Thread.sleep(2000);
return "hello";
};
});
System.out.println("等待结果");
try {
System.out.println("拿到结果:" + future.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
}</span>

四、总结

多线程的创建方式,主要就包括以上的集中。第三种方式则在JDK1.5以后开始使用。总体说来,继承接口的实现,优势是可以同时继承其他类,可以共享实例属性。但是在获取当前线程的时候,则需要使用Thread.currentThread方法,而不能直接使用this获取!接下来,介绍线程通信的问题!
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: