java中线程使用Thread类,所有线程对象都必须是Thread类或其子类的实例
package lianbiao; public class xiancheng extends Thread{ private int i; public void run() { for (; i < 100; i++) { //Thread对象直接调用getName()获取当前线程的名字 System.out.println(getName() + " " + i); } } public static void main(String[] args) { for(int i = 0; i < 100; i++) { //调用Thread的currentThread()方法获取当前线程 System.out.println(Thread.currentThread().getName() + " " + i); if (i == 20) { new xiancheng().start(); //创建并启动第一个线程 new xiancheng().start(); //创建并启动第二个线程 } } } }上面启动了三个线程,一个主线程与两个Thread线程 Thread.currentThread() :返回正在执行的线程对象; getName():返回调用该方法的类的名字;
第一步:定义Runnable接口的实现类,并重写该接口的run方法,该run方法同样是线程需要执行的任务
第二步:创建Runnable实现类的实例,并以此实例作为Thread的target来创建Thread对象,该Thread对象才是真正的线程对象
public class SecondThread implements Runnable { //接口实现 private int i; @Override public void run() { for(;i<100;i++) { System.out.println(Thread.currentThread().getName()+" "+i); } } public static void main(String[] args) { for(int i=0;i<100;i++) { System.out.println(Thread.currentThread().getName()+" "+i); if(i==20) { SecondThread s1=new SecondThread(); new Thread(s1,"新线程1").start();; new Thread(s1,"新线程2").start(); } } } }细心的读者会发现,上面创建线程的两种方法。继承Thread和实现Runnable接口中的run都是没有返回值的。于是从Java5开始,Java提供了Callable接口,该接口是Runnable接口的增强版。Callable接口提供了一个call()方法可以作为线程执行体,但call()方法比run()方法功能更强大。
创建并启动有返回值的线程的步骤如下:
第一步:创建 Callable接口的实现类,并实现call()方法,该call()方法将作为线程执行体,且该call()方法有返回值,再创建 Callable实现类的实例。从Java8开始,可以直接使用 Lambda表达式创建 Callable对象
第二步:使用FutureTask类来包装Callable对象,该FutureTask对象封装了该Callable对象的call方法的返回值
第三步:使用FutureTask对象作为Thread对象的target创建并启动新线程
第四步:通过FutureTask的get()方法获得子线程执行结束后的返回值
import java.util.concurrent.Callable; import java.util.concurrent.FutureTask; public class ThirdThread { public static void main(String[] args) { //ThirdThread rt=new ThirdThread(); FutureTask<Integer> task=new FutureTask<Integer>((Callable<Integer>)()->{ int i=0; for(;i<100;i++) { System.out.println(Thread.currentThread().getName()+"的循环变量i"+i); } return i; }) ; for(int i=0;i<100;i++) { System.out.println(Thread.currentThread().getName()+"的循环变量i为"+i); if(i==20) { new Thread(task,"有返回值的线程").start();; } } try { System.out.println("子线程的返回值"+task.get()); }catch(Exception e) { e.printStackTrace(); } } }