Java线程之三种实现方式(一)

xiaoxiao2021-02-28  47

继承Thread类创建线程类


Thread的实现步骤: 1. 定义Thread的子类,重写run()方法,run()方法代表了线程要完成的任务,run()方法称为线程执行体。 2. 创建Thread子类的实例,子类对象就是线程。 3. 调用线程对象的start()方法来启动线程。

public class ThreadDemo extends Thread{ public void run() { for(int i=0;i<10;i++) { System.out.println(currentThread().getName()+":" + i); } } public static void main(String args[]) { new ThreadDemo().start(); new ThreadDemo().start(); } }

运行结果:

实现Runnable接口创建线程类


Runnable的实现步骤: 1. 定义Runnable接口实现类,重写run()方法,run()方法代表了线程要完成的任务,run()方法称为线程执行体。 2. 创建Runnable实现类的实例,Runnable本身就是Thread类的方法,所以创建线程还要实现一个Thread类来包装Runnable对象。 3. 调用线程对象的start()方法来启动线程。

public class RunnableDemo implements Runnable{ String threadName; public RunnableDemo(String threadName) { this.threadName = threadName; } @Override public void run() { for(int i=0;i<10;i++) { System.out.println(threadName+":" + i); } } public static void main(String args[]) { new Thread(new RunnableDemo("A")).start(); new Thread(new RunnableDemo("B")).start(); } }

运行结果:

实现Callable接口创建线程类


从Java5开始就提供了Callable接口,该接口是Runnable接口的增强版,Callable接口提供一个call()方法作为线程执行体,call()方法可以有返回值,call()方法可以声明抛出异常。

boolean cancel(boolean may) 试图取消该Future里关联的Callable任务。V get() 返回Call任务里call()方法的返回值。调用该方法会照成线程阻塞,必须等待子线程结束后才会得到返回值。V get(long timeout,TimeUnit unit) 返回Call任务里call()方法的返回值。该方法让程序最多阻塞timeout和unit指定的时间,如果经过指定的时间,如果经过指定的时间依然没有返回值,将会抛出TimeoutException异常。boolean isCancelled() 如果在Callable任务正常完成前被取消,则返回true。boolean isDone() 如果Callable任务已完成,则返回true。

Runnable的实现步骤: 1. 创建Callable接口的实现类,并实现call()方法,该call()方法作为线程的执行体,call()方法有返回值。 2. 使用FutrueTask类包装Callable对象。 3. 使用FutrueTask对象作为Thread对象的target创建并启动新线程。 4. 启用FutrueTask对象的get()方法来获得子线程的返回值。

public class CallableDemo implements Callable<Integer> { public static void main(String args[]) { FutureTask<Integer> futureTask = new FutureTask<Integer>(new CallableDemo()); new Thread(futureTask).start(); try { System.out.println("子线程返回值:" + futureTask.get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } if (futureTask.isDone()) { System.out.println("线程结束"); } } @Override public Integer call() throws Exception { System.out.println("线程开始"); int ss = 0; for (int i = 0; i < 20; i++) { ss += i; } return ss; } }

运行结果:

转载请注明原文地址: https://www.6miu.com/read-2612518.html

最新回复(0)