时间:2021-05-20
1.实现Runnable接口,重载run(),无返回值
package thread; public class ThreadRunnable implements Runnable { public void run() { for (int i = 0; i < 10; i++) { System.out.println(Thread.currentThread().getName() + ":" + i); } }} package thread; public class ThreadMain { public static void main(String[] args) throws Exception { ThreadRunnable threadRunnable1 = new ThreadRunnable(); ThreadRunnable threadRunnable2 = new ThreadRunnable(); ThreadRunnable threadRunnable3 = new ThreadRunnable(); ThreadRunnable threadRunnable4 = new ThreadRunnable(); Thread thread1 = new Thread(threadRunnable1); Thread thread2 = new Thread(threadRunnable2); Thread thread3 = new Thread(threadRunnable3); Thread thread4 = new Thread(threadRunnable4); thread1.start(); thread2.start(); thread3.start(); thread4.start(); }}2.继承Thread类,复写run()
使用时通过调用Thread的start()(该方法是native),再调用创建线程的run(),不同线程的run方法里面的代码交替执行。
不足:由于java为单继承,若使用线程类已经有个父类,则不能使用该方式创建线程。
public class ThreadEx extends Thread { public void run() { for (int i = 0; i < 10; i++) { System.out.println(Thread.currentThread() + ":" + i); } }} public class ThreadMain { public static void main(String[] args) { ThreadEx threadEx = new ThreadEx(); threadEx.start(); }}3.实现Callable接口,通过FutureTask/Future来创建有返回值的Thread线程,通过Executor执行
补充:与实现Runnable接口类似,都是实现接口,不同的是该方式有返回值,可以获得异步执行的结果。
延伸:FutureTask是类,Future是接口。
package thread; import java.util.concurrent.*; public class ThreadCallable { public static void main(String[] args) throws Exception { FutureTask<Integer> futureTask = new FutureTask<Integer>(new Callable<Integer>() { public Integer call() throws Exception { for (int i = 0; i < 10; i++) { System.out.println(Thread.currentThread().getName() + ":" + i); } return 1; } }); Executor executor = Executors.newFixedThreadPool(1); ((ExecutorService) executor).submit(futureTask); //获得线程执行状态 System.out.println(Thread.currentThread().getName() + ":" + futureTask.get()); }}4.使用Executors创建ExecutorService,入参Callable或Future
补充:适用于线程池和并发
package thread; import java.util.concurrent.Callable;import java.util.concurrent.Executors;import java.util.concurrent.ThreadFactory; import static java.lang.Thread.sleep; public class ThreadExecutors { private final String threadName; public ThreadExecutors(String threadName) { this.threadName = threadName; } private ThreadFactory createThread() { ThreadFactory tf = new ThreadFactory() { public Thread newThread(Runnable r) { Thread thread = new Thread(); thread.setName(threadName); thread.setDaemon(true); try { sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } return thread; } }; return tf; } public Object runCallable(Callable callable) { return Executors.newSingleThreadExecutor(createThread()).submit(callable); } public Object runFunture(Runnable runnable) { return Executors.newSingleThreadExecutor(createThread()).submit(runnable); }} package thread; import java.util.concurrent.*; public class ThreadMain { public static void main(String[] args) throws Exception { ThreadExecutors threadExecutors = new ThreadExecutors("callableThread"); threadExecutors.runCallable(new Callable() { public String call() throws Exception { return "success"; } }); threadExecutors.runFunture(new Runnable() { public void run() { System.out.println("execute runnable thread."); } }); }}5 Runnable接口和Callable接口区别
6 Callable返回值意义在哪儿,不要返回值可以吗,什么时候需要用到返回值?
首先Callable是线程异步执行的结果状态,如果有两个线程A和B,B中的某个业务逻辑中需要确定A结束后才能进行,那么就需要获得线程A的执行结果。
设计背景:一个任务需要进行一系列操作,比如拷贝大量的基础数据,以及解析数据,并入库,由于数量大,整个过程需要持续十秒左右,用户体验差,需要降低到2~5s。
设计思路:经过分解过程,将拷贝数据分为一个过程,同时涵盖部分解析数据功能,剩下解析数据划为一个过程,两个过程异步执行,其中最后一个任务状态入库时需要将所有业务操作都执行完成后更新,此时就需要用到线程中的返回值。
以上所述是小编给大家介绍的Java创建线程方法详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
java有以下四种创建多线程的方式1:继承Thread类创建线程2:实现Runnable接口创建线程3:使用Callable和FutureTask创建线程4:使
java实现多线程的三种方法在java中,有三种方法可以实现多线程。第一种方法:继承Thread类,重写run函数。第二种方法:实现Runnable接口,重写r
IOS多线程编程NSThread的使用方法NSThread是多线程的一种,有两种方法创建子线程(1)优点:NSThread比GCD、NSOperation都轻量
Java通过Executors提供四种线程池,分别为:newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程
java多线程的三种构建方法继承Thread类创建线程类publicclassThreadextendsObjectimplementsRunnable定义Th