皮皮网

1.带你学会区分ScheduledThreadPoolExecutor与Timer
2.ListenableFuture源码解析
3.动态代理(2)-CGLIB核心原理和JDK区别
4.如何进行ODEX反编译实例
5.Java异步任务优化CompletionService

带你学会区分ScheduledThreadPoolExecutor与Timer

       æ‘˜è¦ï¼šæœ¬æ–‡ç®€å•ä»‹ç»ä¸‹ScheduledThreadPoolExecutor类与Timer类的区别，ScheduledThreadPoolExecutor类相比于Timer类来说，究竟有哪些优势，以及二者分别实现任务调度的简单示例。

       JDK1.5开始提供ScheduledThreadPoolExecutor类，ScheduledThreadPoolExecutor类继承ThreadPoolExecutor类重用线程池实现了任务的周期性调度功能。在JDK1.5之前，实现任务的周期性调度主要使用的是Timer类和TimerTask类。本文，就简单介绍下ScheduledThreadPoolExecutor类与Timer类的区别，ScheduledThreadPoolExecutor类相比于Timer类来说，究竟有哪些优势，以及二者分别实现任务调度的简单示例。

二者的区别线程角度

       Timer是单线程模式，如果某个TimerTask任务的执行时间比较久，会影响到其他任务的调度执行。

       ScheduledThreadPoolExecutor是多线程模式，并且重用线程池，某个ScheduledFutureTask任务执行的时间比较久，不会影响到其他任务的调度执行。

系统时间敏感度

       Timer调度是基于操作系统的绝对时间的，对操作系统的时间敏感，一旦操作系统的时间改变，则Timer的调度不再精确。

       ScheduledThreadPoolExecutor调度是基于相对时间的，不受操作系统时间改变的影响。

是否捕获异常

       Timer不会捕获TimerTask抛出的异常，加上Timer又是单线程的。一旦某个调度任务出现异常，则整个线程就会终止，其他需要调度的任务也不再执行。

       ScheduledThreadPoolExecutor基于线程池来实现调度功能，某个任务抛出异常后，其他任务仍能正常执行。

任务是否具备优先级

       Timer中执行的TimerTask任务整体上没有优先级的概念，只是按照系统的绝对时间来执行任务。

       ScheduledThreadPoolExecutor中执行的ScheduledFutureTask类实现了java.lang.Comparable接口和java.util.concurrent.Delayed接口，这也就说明了ScheduledFutureTask类中实现了两个非常重要的方法，一个是java.lang.Comparable接口的compareTo方法，一个是java.util.concurrent.Delayed接口的getDelay方法。在ScheduledFutureTask类中compareTo方法实现了任务的比较，距离下次执行的时间间隔短的任务会排在前面，也就是说，距离下次执行的时间间隔短的任务的优先级比较高。而getDelay方法则能够返回距离下次任务执行的时间间隔。

是否支持对任务排序

       Timer不支持对任务的排序。

       ScheduledThreadPoolExecutor类中定义了一个静态内部类DelayedWorkQueue，DelayedWorkQueue类本质上是一个有序队列，为需要调度的每个任务按照距离下次执行时间间隔的大小来排序

能否获取返回的结果

       Timer中执行的TimerTask类只是实现了java.lang.Runnable接口，无法从TimerTask中获取返回的结果。

       ScheduledThreadPoolExecutor中执行的ScheduledFutureTask类继承了FutureTask类，能够通过Future来获取返回的结果。

       é€šè¿‡ä»¥ä¸Šå¯¹ScheduledThreadPoolExecutor类和Timer类的分析对比，相信在JDK1.5之后，就没有使用Timer来实现定时任务调度的必要了。

二者简单的示例

       è¿™é‡Œï¼Œç»™å‡ºä½¿ç”¨Timer和ScheduledThreadPoolExecutor实现定时调度的简单示例，为了简便，我这里就直接使用匿名内部类的形式来提交任务。

Timer类简单示例

       æºä»£ç ç¤ºä¾‹å¦‚下所示。

packageio.binghe.concurrent.lab;importjava.util.Timer;importjava.util.TimerTask;/***@authorbinghe*@version1.0.0*@description测试Timer*/publicclassTimerTest{ publicstaticvoidmain(String[]args)throwsInterruptedException{ Timertimer=newTimer();timer.scheduleAtFixedRate(newTimerTask(){ @Overridepublicvoidrun(){ System.out.println("测试Timerç±»");}},源码,);Thread.sleep();timer.cancel();}}

       è¿è¡Œç»“果如下所示。

测试Timer类测试Timer类测试Timer类测试Timer类测试Timer类测试Timer类测试Timer类测试Timer类测试Timer类测试Timer类ScheduledThreadPoolExecutor类简单示例

       æºä»£ç ç¤ºä¾‹å¦‚下所示。

packageio.binghe.concurrent.lab;importjava.util.concurrent.*;/***@authorbinghe*@version1.0.0*@description测试ScheduledThreadPoolExecutor*/publicclassScheduledThreadPoolExecutorTest{ publicstaticvoidmain(String[]args)throwsInterruptedException{ ScheduledExecutorServicescheduledExecutorService=Executors.newScheduledThreadPool(3);scheduledExecutorService.scheduleAtFixedRate(newRunnable(){ @Overridepublicvoidrun(){ System.out.println("测试测试ScheduledThreadPoolExecutor");}},1,1,TimeUnit.SECONDS);//主线程休眠秒Thread.sleep();System.out.println("正在关闭线程池...");//关闭线程池scheduledExecutorService.shutdown();booleanisClosed;//等待线程池终止do{ isClosed=scheduledExecutorService.awaitTermination(1,TimeUnit.DAYS);System.out.println("正在等待线程池中的任务执行完成");}while(!isClosed);System.out.println("所有线程执行结束，线程池关闭");}}

       è¿è¡Œç»“果如下所示。

测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor测试测试ScheduledThreadPoolExecutor正在关闭线程池...测试测试ScheduledThreadPoolExecutor正在等待线程池中的任务执行完成所有线程执行结束，线程池关闭

       æ³¨æ„ï¼šå…³äºŽTimer和ScheduledThreadPoolExecutor还有其他的使用方法，这里，我就简单列出以上两个使用示例，更多的使用方法大家可以自行实现。

       æœ¬æ–‡åˆ†äº«è‡ªåŽä¸ºäº‘社区《【高并发】ScheduledThreadPoolExecutor与Timer的区别和简单示例》，作者：冰河。

ListenableFuture源码解析

       ListenableFuture 是 spring 中对 JDK Future 接口的扩展，主要应用于解决在提交线程池的详解任务拿到 Future 后在 get 方法调用时会阻塞的问题。通过使用 ListenableFuture，源码可以向其注册回调函数（监听器），详解当任务完成时，源码触发回调。详解强力django 源码Promise 在 Netty 中也实现了类似的源码功能，用于处理类似 Future 的详解场景。

       实现 ListenableFuture 的源码关键在于 FutureTask 的源码解析。FutureTask 是详解实现 Future 接口的基础类，ListenableFutureTask 在其基础上做了扩展。源码其主要功能是详解在任务提交后，当调用 get 方法时能够阻塞当前业务线程，源码直到任务完成时唤醒。详解

       FutureTask 通过在内部实现一个轻量级的源码e语言转盘源码 Treiber stack 数据结构来管理等待任务完成的线程。这个数据结构由 WaitNode 节点组成，每个节点代表一个等待的线程。当业务线程调用 get 方法时，会将自己插入到 WaitNode 栈中，并且在插入的同时让当前线程进入等待状态。在任务执行完成后，会遍历 WaitNode 栈，唤醒等待的线程。

       为了确保并发安全，FutureTask 使用 CAS（Compare and Swap）操作来管理 WaitNode 栈。每个新插入的节点都会使用 CAS 操作与栈顶节点进行比较，并在满足条件时更新栈顶。这一过程保证了插入操作的原子性，防止了并发条件下的python 包的源码数据混乱。同时，插入操作与栈顶节点的更新操作相互交织，确保了数据的一致性和完整性。

       在 FutureTask 中，还利用了 LockSupport 类提供的 park 和 unpark 方法来实现线程的等待和唤醒。当线程插入到 WaitNode 栈中后，通过 park 方法将线程阻塞；任务执行完成后，通过 unpark 方法唤醒线程，完成等待与唤醒的流程。

       综上所述，ListenableFuture 通过扩展 FutureTask 的功能，实现了任务执行与线程等待的高效管理。通过注册监听器并利用 CAS 操作与 LockSupport 方法，实现了在任务完成时通知回调，Web 报表系统 源码解决了异步任务执行时的线程阻塞问题，提高了程序的并发处理能力。

动态代理(2)-CGLIB核心原理和JDK区别

       在先前的文章中，我们探讨了动态代理的应用以及JDK动态代理的核心原理。本文将继续探讨CGLIB的核心原理及其与JDK动态代理的区别。

       JDK动态代理存在一个限制，它无法代理那些没有实现接口的对象。这是因为动态代理需要通过实现接口来创建代理类。然而，这种限制在实际应用中可能引起一些不便。例如，当需要代理一个没有接口的第三方类，或者根本不希望编写接口时，这种限制就变得尤为明显。服务到期提醒 源码正是在这种背景下，CGLIB应运而生。

       CGLIB通过创建一个继承目标类的代理类来实现动态代理。与JDK动态代理不同，CGLIB不通过实现接口来创建代理类，而是通过继承来达到目的。尽管方法的工作逻辑都需要在外部定义，并将其传递给自动生成的代理类，但CGLIB和JDK动态代理在这一方面是相似的。

       在代码层面，CGLIB的使用方式与JDK动态代理相似。用户首先提出代理需求，然后Java自动生成代理类。这种模式在CGLIB中同样适用。

       CGLIB的核心源码包括创建代理逻辑和生成class对象的方法。在创建代理逻辑时，CGLIB使用缓存机制来提高性能。当需要创建代理类时，如果缓存中不存在对应的类对象，则会将其包装为一个异步任务FutureTask，并将其放置在缓存中。这种设计可以有效地处理多线程环境下类对象的创建。

       CGLIB生成的类包括代理对象类和两个FastClass。FastClass是对代理类和目标类方法的签名hash映射，这使得CGLIB可以直接调用这些方法，避免了反射调用。

       总结来说，CGLIB和JDK动态代理在实现方式、性能和适用场景上存在一定的差异。JDK动态代理要求目标类实现接口，而CGLIB可以代理没有接口的类。此外，CGLIB采用继承的方式创建代理类，而JDK动态代理通过实现接口。在性能方面，CGLIB采用FastClass机制，避免了反射调用，从而提高了性能。

如何进行ODEX反编译实例

       0x 前言

       ä½¿ç”¨å¼€æºå·¥å…·å‡ºçŽ°é—®é¢˜è€Œä¸”很难在网上查找到解决方案的时候，最好的解决方法就是研究它的源码，因为那样能为我们提供更多的信息。

       0x 搭建smali/baksmali源码调试环境

       é¦–先我们在github上拉取smali/baksmali的源码

       git clone /JesusFreke/smali.git

       å¯ä»¥çœ‹å‡ºè¯¥é¡¹ç›®é‡‡ç”¨äº†grade自动化构建工具来编译源码的，因此我们可以在android studio中导入该项目，如下图所示：

       ç”Ÿæˆçš„baksmali在如下目录下面：

       ä¸Šå›¾ä¸­çš„Program arguments中，-a选项代表api level，可以通过如下属性获得：

       æŠ¥é”™å¦‚下：

       Error occurred while disassembling classLandroid.support.v4.util.TimeUtils; - skipping class

       java.lang.RuntimeException: Invalid methodindex:

       atorg.jf.dexlib2.analysis.InlineMethodResolver$InlineMethodResolver_version.resolveExecuteInline(InlineMethodResolver.java:)

       atorg.jf.dexlib2.analysis.MethodAnalyzer.analyzeExecuteInline(MethodAnalyzer.java:)

       atorg.jf.dexlib2.analysis.MethodAnalyzer.analyzeInstruction(MethodAnalyzer.java:)

       atorg.jf.dexlib2.analysis.MethodAnalyzer.analyze(MethodAnalyzer.java:)

       atorg.jf.dexlib2.analysis.MethodAnalyzer.<init>(MethodAnalyzer.java:)

       atorg.jf.baksmali.Adaptors.MethodDefinition.addAnalyzedInstructionMethodItems(MethodDefinition.java:)

       atorg.jf.baksmali.Adaptors.MethodDefinition.getMethodItems(MethodDefinition.java:)

       atorg.jf.baksmali.Adaptors.MethodDefinition.writeTo(MethodDefinition.java:)

       atorg.jf.baksmali.Adaptors.ClassDefinition.writeDirectMethods(ClassDefinition.java:)

       atorg.jf.baksmali.Adaptors.ClassDefinition.writeTo(ClassDefinition.java:)

       atorg.jf.baksmali.baksmali.disassembleClass(baksmali.java:)

       atorg.jf.baksmali.baksmali.access$(baksmali.java:)

       atorg.jf.baksmali.baksmali$1.call(baksmali.java:)

       atorg.jf.baksmali.baksmali$1.call(baksmali.java:)

       atjava.util.concurrent.FutureTask.run(FutureTask.java:)

       atjava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:)

       atjava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:)

       atjava.lang.Thread.run(Thread.java:)

       æˆ‘们直接锁定出错的地方，在上面出错信息标红色的地方，并且在抛出异常处下断点，我们可以判断出错原因是因为反编译smali指令execute-line时传入了一个未知的Dalvik虚拟机的内部java方法索引inlineIndex=：

       ç„¶åŽï¼Œæˆ‘们把inline.txt作为-T选项的参数传递进去：

Java异步任务优化CompletionService

       在Java异步编程中，CompletionService扮演着优化Future和Callable任务的角色。传统Future设计的缺陷在于通过get方法获取结果时，如果任务未完成则阻塞线程，导致资源占用和效率低下。尤其在处理一批任务时，未完成任务的后续处理需等待所有任务完成，造成资源浪费和不合理的等待时间。

       为解决上述问题，CompletionService应运而生。它允许同时提交多个任务，优先处理已完成的任务。通过使用ExecutorCompletionService作为CompletionService的实现类，开发者只需设置线程池并提交任务，CompletionService将自动管理任务的执行和结果的获取。

       具体而言，ExecutorCompletionService的关键步骤包括设置线程池、提交任务和通过take方法获取已完成任务的Future。借助其内部类QueueingFuture，任务完成时会自动调用done方法，将任务结果放入阻塞队列中，进而被后续调用take方法的程序获取。

       解析源码可见，ExecutorCompletionService的核心逻辑简明扼要。它通过submit方法将任务封装为FutureTask并作为QueueingFuture的属性保存，提交至线程池执行。执行完毕后，run方法调用done方法将FutureTask添加至阻塞队列。最后，take方法从队列中获取已完成的任务。

       总结而言，CompletionService通过优化任务执行和结果获取流程，显著提高了异步任务的执行效率和资源利用。作为Java程序员，理解和掌握CompletionService的使用，对于优化代码性能至关重要。