java多线程有几种实现方法

本教程操作环境：windows7系统、java10版，DELL G3电脑。

1、lambda表达式创建线程

使用lambda的形式实例化线程任务类，创建线程对象,并将线程任务类作为构造方法参数传入。

packagecom.kingh.thread.create;

/**
*创建线程withlambda
*
*@author<ahref="https://blog.csdn.net/king_kgh>Kingh</a>
*@version1.0
*@date2019/3/1810:04
*/
publicclassCreateThreadDemo5_Lambda{

publicstaticvoidmain(String[]args)throwsException{
//使用lambda的形式实例化线程任务类
Runnabletask=()->{
while(true){
//输出线程的名字
printThreadInfo();
}
};

//创建线程对象,并将线程任务类作为构造方法参数传入
newThread(task).start();

//主线程的任务，为了演示多个线程一起执行
while(true){
printThreadInfo();
Thread.sleep(1000);
}
}

/**
*输出当前线程的信息
*/
privatestaticvoidprintThreadInfo(){
System.out.println("当前运行的线程名为："+Thread.currentThread().getName());
try{
Thread.sleep(1000);
}catch(Exceptione){
thrownewRuntimeException(e);
}
}
}

2、使用ExecutorService、Callable、Future实现有返回结果的多线程

可以返回值的任务必须是Callable接口，类似的，没有返回值的任务必须是Runnable接口。执行Callable任务后，可以获得一个Future对象，通过调用get可以获得Callable任务返回的Object，然后结合线程池接口ExecutorService可以实现传说中有返回结果的多线程。

importjava.util.concurrent.*;
importjava.util.Date;
importjava.util.List;
importjava.util.ArrayList;

/**
*有返回值的线程
*/
@SuppressWarnings("unchecked")
publicclassTest{
publicstaticvoidmain(String[]args)throwsExecutionException,
InterruptedException{
System.out.println("----程序开始运行----");
Datedate1=newDate();

inttaskSize=5;
//创建一个线程池
ExecutorServicepool=Executors.newFixedThreadPool(taskSize);
//创建多个有返回值的任务
List<Future>list=newArrayList<Future>();
for(inti=0;i<taskSize;i++){
Callablec=newMyCallable(i+"");
//执行任务并获取Future对象
Futuref=pool.submit(c);
//System.out.println(">>>"+f.get().toString());
list.add(f);
}
//关闭线程池
pool.shutdown();

//获取所有并发任务的运行结果
for(Futuref:list){
//从Future对象上获取任务的返回值，并输出到控制台
System.out.println(">>>"+f.get().toString());
}

Datedate2=newDate();
System.out.println("----程序结束运行----，程序运行时间【"
+(date2.getTime()-date1.getTime())+"毫秒】");
}
}

classMyCallableimplementsCallable<Object>{
privateStringtaskNum;

MyCallable(StringtaskNum){
this.taskNum=taskNum;
}

publicObjectcall()throwsException{
System.out.println(">>>"+taskNum+"任务启动");
DatedateTmp1=newDate();
Thread.sleep(1000);
DatedateTmp2=newDate();
longtime=dateTmp2.getTime()-dateTmp1.getTime();
System.out.println(">>>"+taskNum+"任务终止");
returntaskNum+"任务返回运行结果,当前任务时间【"+time+"毫秒】";
}
}