核心内容摘要
碧波余晖下的羁绊：当泳装小南遇上“萌娘”长门，那根大萝卜究竟藏着什么秘密？
文章目录Java多线程编程技巧面试必看的几种实现方式为什么我们需要多线程Java多线程的实现方式
继承Thread类
实现Runnable接口
实现Callable接口
使用线程池ThreadPoolExecutor
并行流Java 8线程安全与同步机制
synchronized关键字
ReentrantLock
volatile关键字死锁与解决方法
避免死锁的方法
检测死锁的方法实战案例银行转账问题问题描述解决方案代码解释
总结如果你有任何问题或想深入探讨某个主题欢迎随时提问闫工也会继续为大家带来更多精彩的讲解。
领取 | 1000 套高质量面试题大合集无套路闫工带你飞一把Java多线程编程技巧面试必看的几种实现方式大家好欢迎来到闫工的博客今天我们要聊的是Java多线程编程的一些经典实现方式。
作为一个长期奋斗在一线的码农闫工深知多线程在Java面试中占据的重要地位。
所以这篇文章不仅要让你明白多线程的基本原理更要掌握几种常见的实现方式以及如何在面试中脱颖而出。
为什么我们需要多线程在开始讲解具体实现方式之前闫工先问大家一个问题为什么要使用多线程相信很多同学会说“为了提高程序的执行效率”或者“让程序更高效地利用CPU资源”。
没错但还有一个更重要的原因多线程可以让你的程序看起来更酷比如当你在看视频的时候下载进度条在动同时还能和朋友聊QQ。
这背后就是多线程在默默工作。
Java多线程的实现方式Java提供了多种实现多线程的方式闫工在这里为大家
总结了几种最常见的方法
继承Thread类这是最基础也是最容易上手的方法。
只要你的类继承了Thread就可以重写run()方法并通过调用start()来启动线程。
代码示例publicclassMyThreadextendsThread{Overridepublicvoidrun(){System.out.println(闫工说我在新线程中运行);}}// 使用方式MyThreadthreadnewMyThread();thread.start();// 这里会启动一个新的线程并执行run方法注意点不要重写start()方法它会被JVM用来管理线程生命周期。
如果你只是想实现多线程继承Thread并不是最优的选择。
因为这样可能会带来不必要的耦合。
实现Runnable接口相比于直接继承Thread类实现Runnable接口更加灵活。
因为Java只支持单一继承如果你的类已经继承了其他类就不能再继承Thread了。
代码示例publicclassMyRunnableimplementsRunnable{Overridepublicvoidrun(){System.out.println(闫工说用Runnable接口实现多线程);}}// 使用方式MyRunnablerunnablenewMyRunnable();newThread(runnable).start();优点更灵活不会导致类的单继承问题。
可以传递参数这在实际开发中非常有用。
实现Callable接口Callable是Java 5引入的一个接口它和Runnable类似但有两点不同call()方法可以返回一个结果。
call()方法可以抛出异常。
代码示例importjava.util.concurrent.Callable;importjava.util.concurrent.ExecutionException;importjava.util.concurrent.FutureTask;publicclassMyCallableimplementsCallableString{OverridepublicStringcall()throwsException{return闫工说用Callable实现多线程还能返回结果;}publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{MyCallablecallablenewMyCallable();FutureTaskStringfutureTasknewFutureTask(callable);ThreadthreadnewThread(futureTask);thread.start();System.out.println(线程执行结果futureTask.get());}}注意点如果你需要获取线程的返回值Callable和Future是你的最佳选择。
futureTask.get()是一个阻塞方法会一直等待直到任务完成。
使用线程池ThreadPoolExecutor对于需要频繁创建和销毁线程的场景直接使用Thread类或Runnable可能会带来性能上的开销。
这时候线程池就成了我们的救星。
代码示例importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;publicclassThreadPoolExample{publicstaticvoidmain(String[]args){// 创建一个固定大小的线程池大小为5ExecutorServiceexecutorServiceExecutors.newFixedThreadPool(
;for(inti0;i10;i){Runnabletask()-System.out.println(闫工说这是第 Thread.currentThread().getName() 号线程);executorService.submit(task);}// 关闭线程池executorService.shutdown();}}优点线程复用减少频繁创建销毁线程带来的开销。
提供丰富的配置选项比如固定大小的线程池、可缓存的线程池等。
并行流Java 8如果你觉得上面的方法太“老套”那么可以试试Java 8引入的并行流。
它可以帮助你在函数式编程中轻松实现多线程。
代码示例importjava.util.stream.IntStream;publicclassParallelStreamExample{publicstaticvoidmain(String[]args){IntStream.range(1,
.parallel().forEach(i-System.out.println(闫工说这是第 i 号线程));}}注意点并行流内部会自动管理线程池但你无法直接控制线程的数量。
如果你的任务之间有依赖关系使用并行流可能会导致问题。
线程安全与同步机制在多线程编程中一个绕不开的话题就是线程安全。
闫工在这里为大家介绍几种常见的同步机制
synchronized关键字Synchronized是Java中最基本的同步机制它可以修饰方法或代码块。
代码示例publicclassSynchronizedExample{privateintcount0;publicsynchronizedvoidincrement(){// 方法级别的同步count;}publicvoidanotherMethod(){synchronized(this){// 块级别的同步System.out.println(闫工说这是块级别的同步);}}}注意点Synchronized会带来一定的性能开销因为它会导致其他线程等待。
选择合适的锁对象非常重要否则可能会导致死锁。
ReentrantLock如果你觉得synchronized不够灵活那么可以试试ReentrantLock。
它提供了更精细的控制并且支持公平锁和非公平锁。
代码示例importjava.util.concurrent.locks.ReentrantLock;publicclassReentrantLockExample{privatefinalReentrantLocklocknewReentrantLock();privateintcount0;publicvoidincrement(){lock.lock();// 加锁try{count;}finally{lock.unlock();// 解锁确保不会出现死锁}}}优点更灵活的控制支持公平锁和非公平锁。
可以尝试获取锁tryLock()而不会阻塞当前线程。
volatile关键字Volatile是Java中的一个轻量级同步机制它确保了变量的修改对所有线程都是可见的。
代码示例publicclassVolatileExample{privatevolatilebooleanflagfalse;publicvoidsetFlag(booleanvalue){this.flagvalue;}publicvoidcheckFlag(){while(!flag){System.out.println(闫工说flag 还是 false继续等待);Thread.sleep(
;}System.out.println(闫工说flag 已经变成 true 了);}}注意点Volatile不能替代synchronized因为它只能保证可见性而无法保证原子性。
它适用于那些不需要复杂操作的场景。
死锁与解决方法在多线程编程中死锁是一个常见的问题。
下面闫工为大家介绍如何避免和检测死锁
避免死锁的方法顺序访问资源确保所有线程都以相同的顺序获取资源。
使用超时机制在尝试获取锁时设置一个超时时间防止无限等待。
检测死锁的方法JDK工具可以使用jstack命令来查看当前的线程状态。
内置监控Java提供了ManagementFactory类可以通过它获取死锁的信息。
实战案例银行转账问题为了让大家更好地理解多线程编程的实际应用闫工在这里为大家讲解一个经典的银行转账问题。
问题描述假设有一个银行账户A和账户B现在需要从账户A向账户B转账100元。
在这个过程中可能会出现多个线程同时操作这两个账户的情况导致金额不一致的问题。
解决方案为了确保转账过程的原子性我们可以使用synchronized关键字来控制同步。
代码示例importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassBankTransfer{privateAccountaccountAnewAccount(A,
;privateAccountaccountBnewAccount(B,
;// 使用两个锁来避免死锁privateLocklockAnewReentrantLock();privateLocklockBnewReentrantLock();publicvoidtransfer(){try{if(lockA.tryLock(1,TimeUnit.SECONDS)){// 尝试获取 accountA 的锁超时时间为1秒try{if(lockB.tryLock(1,TimeUnit.SECONDS)){// 尝试获取 accountB 的锁超时时间为1秒try{accountA.debit(
;accountB.credit(
;}finally{lockB.unlock();// 释放 accountB 的锁}}}finally{lockA.unlock();// 释放 accountA 的锁}}}catch(InterruptedExceptione){Thread.currentThread().interrupt();}}publicstaticvoidmain(String[]args){BankTransferbankTransfernewBankTransfer();for(inti0;i5;i){ThreadthreadnewThread(bankTransfer::transfer);thread.start();}}}classAccount{privateStringname;privateintbalance;publicAccount(Stringname,intbalance){this.namename;this.balancebalance;}publicsynchronizedvoiddebit(intamount){// 同步方法防止并发修改System.out.println(闫工说从 name 账户扣除 amount 元。
);balance-amount;System.out.println(name 账户当前余额balance);}publicsynchronizedvoidcredit(intamount){// 同步方法防止并发修改System.out.println(闫工说向 name 账户存入 amount 元。
);balanceamount;System.out.println(name 账户当前余额balance);}}代码解释BankTransfer类包含两个账户accountA和accountB。
使用了两个ReentrantLock锁来分别控制对两个账户的操作避免死锁问题。
transfer()方法中使用了tryLock()方法并设置了超时时间防止无限等待。
Account类每个账户都有一个名称和余额。
提供了debit()扣款和credit()存款方法并且这两个方法都是同步的确保同一时间只有一个线程可以操作该账户。
总结通过今天的讲解希望大家对多线程编程有了更深入的理解。
记住在实际开发中合理使用线程并不是所有场景都需要多线程有时候单线程反而更容易维护。
注意线程安全确保共享资源的访问是同步的避免竞态条件和死锁。
选择合适的工具根据具体需求选择合适的方式来管理线程和同步机制。
如果你有任何问题或想深入探讨某个主题欢迎随时提问闫工也会继续为大家带来更多精彩的讲解。
领取 | 1000 套高质量面试题大合集无套路闫工带你飞一把成体系的面试题无论你是大佬还是小白都需要一套JAVA体系的面试题我已经上岸了你也想上岸吗闫工精心准备了程序准备面试想系统提升技术实力闫工精心整理了1000 套涵盖前端、后端、算法、数据库、操作系统、网络、设计模式等方向的面试真题 详细解析并附赠高频考点