皮皮网

1.parallelStream 基本原理
2.TerminateProcess HOOK
3.功能更新生成源码异步下载，任务任务让系统响应速度提升10倍
4.Matrix卡顿优化之IdleHandlerLagTracer源码分析
5.利用Cython加速计算密集型python任务

parallelStream 基本原理

       stream流是列表java在jdk1.8中引入的工具，旨在简化任务处理，源码源码让我们专注于实现细节，任务任务而无需关注任务调度，列表由stream自动实现调度。源码源码金豹源码例如，任务任务如果我们需要对列表进行求和，列表只需通过列表生成流，源码源码使用reduce方法传递表达式即可，任务任务省去了for循环和if判断等繁琐操作。列表默认情况下，源码源码stream是任务任务单线程执行的。

       对于需要并行执行的列表场景，例如同时计算多个任务结果，源码源码java提供了parallelStream。通过parallelStream，可将上述例子中先计算1+2，再计算3+3的方式，优化为同时计算1+2和3+3，利用处理器的多核性能提升效率。parallelStream内部通过ForkJoinPool的commonPool线程执行任务，大大简化了并行编程的复杂性。

       探究parallelStream如何利用ForkJoinPool，首先，integers.parallelStream()返回Stream对象，parallel属性为true，表明这是呼叫中心程序源码并行流。接下来，调用stream.reduce方法处理流。在reduce（）源码中，它主要通过调用evaluate（）方法处理流。evaluate（）首先检查linkedOrConsumed属性，确保流未被消费。对于并行流，evaluate（）创建ReduceTask，并通过其invoke方法执行计算。

       ReduceTask是ForkJoinTask的子类，它不重写invoke方法，因此调用ReduceTask.invoke()等同于调用ForkJoinTask.invoke()。这样，parallelStream通过ForkJoinTask实现了并行流处理，具体通过递归任务分解和并行执行实现。

TerminateProcess HOOK

       å¦‚何保证自己的程序不被关闭？

       å°±ç®—是一些进程软件也不可以关闭

       samba 我听过有人采用程序互相监控的方法来达到目的。

       ä½†è¿™æ ·å°±ä¼šå ç”¨ç³»ç»Ÿèµ„源。一个不加什么控件的纯窗体都要3占用MB内存，

       å¦‚果加上我本来的那个程序，岂不是要占去十几MB内存，这对于我那个小程序来讲不不可忍受的。

       è¯·é—®æœ‰ä»€ä¹ˆæ¯”较好的方法可以解决？有这方面的控件吗？先谢过大家了！

       ---------------------------------------------------------------

       åœ¨WINDOWS操作系统下，当我们无法结束或者不知道怎样结束一个程序的时候，或者是懒得去找“退出”按钮的时候，通常会按“CTRL+ALT+DEL”呼出任务管理器，找到想结束的程序，点一下“结束任务”就了事了，呵呵，虽然有点粗鲁，但大多数情况下都很有效，不是吗？

        设想一下，如果有这么一种软件，它所要做的工作就是对某个使用者在某台电脑上的活动作一定的限制，而又不能被使用者通过“结束任务”这种方式轻易地解除限制，那该怎么做？无非有这么三种方法：1.屏蔽“CTRL+ALT+DEL”这个热键的组合；2.让程序不出现在任务管理器的列表之中；3.让任务管理器无法杀掉这个任务。对于第一种方法，这样未免也太残酷了，用惯了“结束任务”这种方法的人会很不习惯的；对于第二种方法，在WINDOWS 9X下可以很轻易地使用注册服务进程的方法实现，但是对于WINDOWS NT架构的操作系统没有这个方法了，进程很难藏身，虽然仍然可以实现隐藏，但实现机制较为复杂；对于第三种方法，实现起来比较简单，我的作品：IPGate 网址过滤器 就是采用的这种方式防杀的，接下来我就来介绍这种方法。

        任务管理器的“结束任务”实际上就是强制终止进程，它所使用的杀手锏是一个叫做TerminateProcess()的Win API函数，我们来看看它的定义：

       BOOL TerminateProcess(

        HANDLE hProcess; // 将被结束进程的句柄

        UINT uExitCode; // 指定进程的退出码

       );

        看到这里，是不是觉得不必往下看都知道接下来要做什么：Hook TerminateProcess()函数，每次TerminateProcess()被调用的时候先判断企图结束的进程是否是我的进程，如果是的话就简单地返回一个错误码就可以了。真的是这么简单吗？先提出一个问题，如何根据hProcess判断它是否是我的进程的句柄？答案是：在我的进程当中先获得我的进程的句柄，然后通过进程间通讯机制传递给钩子函数，与hProcess进行比较不就行了？错！因为句柄是一个进程相关的值，不同进程中得到的我的进程的句柄的值在进程间进行比较是无意义的。

        怎么办？我们来考察一下我的hProcess它是如何得到的。一个进程只有它的进程ID是独一无二的，操作系统通过进程ID来标识一个进程，当某个程序要对这个进程进行访问的话，它首先得用OpenProcess这个函数并传入要访问的进程ID来获得进程的句柄，来看看它的参数：

       HANDLE OpenProcess(

       DWORD dwDesiredAccess, // 希望获得的访问权限

       BOOL bInheritHandle, // 指明是否希望所获得的句柄可以继承

       DWORD dwProcessId // 要访问的进程ID

       );

        脉络渐渐显现：在调用TerminateProcess()之前，必先调用OpenProcess()，而OpenProcess()的参数表中的dwProcessId是在系统范围内唯一确定的。得出结论：要Hook的函数不是TerminateProcess()而是OpenProcess()，在每次调用OpenProcess()的时候，我们先检查dwProcessId是否为我的进程的ID(利用进程间通讯机制)，如果是的话就简单地返回一个错误码就可以了，任务管理器拿不到我的进程的句柄，它如何结束我的进程呢？

        至此，疑团全部揭开了。由Hook TerminateProcess()到Hook OpenProcess()的这个过程，体现了一个逆向思维的思想。其实我当初钻进了TerminateProcess()的死胡同里半天出也不来，但最终还是蹦出了灵感的火花，注意力转移到了OpenProcess()上面，实现了进程防杀。喜悦之余，将这心得体会拿出来与大家分享。

       ---------------------------------------------------------------

       è¦ä¸æˆ‘给你把我的可执行文件的源代码和动态连接库发给你好了

       åŠ¨æ€è¿žæŽ¥åº“你自己可以换掉

       å°±æ˜¯è¦æ³¨å…¥çš„那个

       ï¼Œæ³¨å…¥åˆ°çš„目标程序你自己设置

       ---------------------------------------------------------------

       å‘µå‘µï¼Œæˆ‘成功实现了：）

       é€šè¿‡setwindowshookex建立CBT的Hook，Hook DLL中加载API重定向，就可以达到全局有效的APIHOOK效果了，还要对MapFile操作，以便统一全局的参数

       ä¸‹è½½åœ°å€ï¼š/lysoft/projects/API Hook.rar

       by Liu Yang

       ---------------------------------------------------------------

       ä¸Šé¢çš„例子，很厉害的，不只是任务管理器，连别的第三方软件都奈何不得！

       ç¦æ­¢ CTRL+ALT+DELETE under XP and Win, 的方法，不过容易破解

       å¦å¤–，XP下Gina方法是不行的，我提供的Demo就没问题了。至于那个DLL是怎么写的，就不便公开了。调用接口就在代码中，呵呵，花了我3天功夫才搞好。有点累了，休息了。

       procedure DisableTaskMgr(bTF: Boolean);

       var

        reg: TRegistry;

       begin

        reg := TRegistry.Create;

        reg.RootKey := HKEY_CURRENT_USER;

        reg.OpenKey('Software', True);

        reg.OpenKey('Microsoft', True);

        reg.OpenKey('Windows', True);

        reg.OpenKey('CurrentVersion', True);

        reg.OpenKey('Policies', True);

        reg.OpenKey('System', True);

        if bTF = True then

        begin

        reg.WriteString('DisableTaskMgr', '1');

        end

        else if bTF = False then

        begin

        reg.DeleteValue('DisableTaskMgr');

        end;

        reg.CloseKey;

       end;

       // Example Call:

       procedure TForm1.Button1Click(Sender: TObject);

       begin

        DisableTaskMgr(True);

       end;

       ---------------------------------------------------------------

       type //定义一个入口结构

        PImage_Import_Entry = ^Image_Import_Entry;

        Image_Import_Entry = record

        Characteristics: DWORD; //"code"or"data"or"bss"

        TimeDateStamp: DWORD;

        MajorVersion: Word;

        MinorVersion: Word;

        Name: DWORD; //所属动态库或程序的名称

        LookupTable: DWORD;

        end;

       type //定义一个跳转的结构

        TImportCode = packed record

        JumpInstruction: Word; //定义跳转指令jmp

        AddressOfPointerToFunction: ^Pointer; //定义要跳转到的函数

        end;

        PImportCode = ^TImportCode;

       implementation

       //返回当前函数地址

       function LocateFunctionAddress(Code: Pointer): Pointer;

       var

        func: PImportCode;

       begin

        Result := Code;

        if Code = nil then exit;

        try

        func := code;

        if (func.JumpInstruction = $FF) then

        begin

        Result := func.AddressOfPointerToFunction^;

        end;

        except

        Result := nil;

        end;

       end;

       //改变函数的指向

       function RepointFunction(OldFunc, NewFunc: Pointer): Integer;

       var

        IsDone: TList;

        //将指定实例中的引入函数定位为新函数

        function RepointAddrInModule(hModule: THandle; OldFunc, NewFunc: Pointer): Integer;

        var

        Dos: PImageDosHeader;//dos head

        NT: PImageNTHeaders; //nt head

        ImportDesc: PImage_Import_Entry; //函数入口地址

        RVA: DWORD;

        Func: ^Pointer;

        DLL: string;

        f: Pointer;

        written: DWORD;

        begin

        Result := 0;

        Dos := Pointer(hModule);//实例句柄

        if IsDone.IndexOf(Dos) >= 0 then exit; //是否已经替换过此实例句柄

        IsDone.Add(Dos); //添加实例句柄

        OldFunc := LocateFunctionAddress(OldFunc);

        if IsBadReadPtr(Dos, SizeOf(TImageDosHeader)) then exit;

        if Dos.e_magic <> IMAGE_DOS_SIGNATURE then exit;//判断是否是合法的dos头

        NT := Pointer(Integer(Dos) + dos._lfanew);//得到pe头

        //得到输入函数的相关虚地址

        RVA := NT^.OptionalHeader.DataDirectory[IMAGE_DIRECTORY_ENTRY_IMPORT].VirtualAddress;

        if RVA = 0 then exit;

        //计算实际第一个输入函数地址

        ImportDesc := pointer(integer(Dos) + RVA);

        while (ImportDesc^.Name <> 0) do

        begin

        //得到输入的动态库名称

        DLL := PChar(Integer(Dos) + ImportDesc^.Name);

        //递归到另一个动态库

        RepointAddrInModule(GetModuleHandle(PChar(DLL)), OldFunc, NewFunc);

        //计算引入函数在程序中的调入地址

        Func := Pointer(Integer(DOS) + ImportDesc.LookupTable);

        while Func^ <> nil do

        begin

        f := LocateFunctionAddress(Func^);

        //找寻引入的函数

        if f = OldFunc then

        begin

        //注入新函数地址

        WriteProcessMemory(GetCurrentProcess, Func, @NewFunc, 4, written);

        if Written > 0 then Inc(Result);

        end;

        Inc(Func);

        end;

        Inc(ImportDesc);

        end;

        end;

       begin

        IsDone := TList.Create;

        try

        Result := RepointAddrInModule(GetModuleHandle(nil), OldFunc, NewFunc);

        finally

        IsDone.Free;

        end;

       end;

功能更新生成源码异步下载，让系统响应速度提升倍

       通过本次优化更新，系统在生成源码、流程执行轨迹展示、SQL修改提示、系统函数的jar包定义、运维API依赖JAR包的引入、以及定时任务jar包的管理上，采用了异步操作模式，显著提升了系统响应速度与性能。下面详细解读各项功能的优化点和操作流程。

       1. 生成源码异步下载优化

       优化后，力王头像源码生成源码时将采用异步下载策略。操作流程如下：

       点击项目卡片的“设置按钮”并选择“生成源码”。

       在弹出的二次提示框中，选择是否携带JAR包，确认后点击“确定”。

       再次点击项目卡片上的“设置按钮”进入“源码记录”。

       在源码记录列表中可实时查看生成状态，生成完成后即可下载源码包。

       若生成失败，点击操作栏的“详情”按钮查看具体原因。

       2. 流程执行轨迹变量展示优化

       优化后的流程执行轨迹功能，不仅能显示当前组件信息，还支持查看流程中其他组件的详细信息。系统变量信息被分类为入口参数、局部变量、配置组参数和基础参数，便于用户快速了解组件执行结果和变量值。

       3. 修改SQL使用提示优化

       当SQL信息被接口引用时，修改SQL后系统将弹出提示，要求在接口中重新选择该SQL信息后才能生效。删除SQL时，系统会提示已引用的接口，需先去除引用后才能执行删除操作。

       4. 系统函数jar包定义为扩展jar包优化

       系统将一些常用函数定义为扩展jar包，仅在需要时自动加载，减少执行引擎包体积，提升性能。竞价成交金额源码以“SysFun_Feidai_BaseUtilsBaseUtils”为例，进行加载与使用。

       5. 运维API依赖JAR包引入优化

       监控检测扩展jar包在本地客户端和执行引擎中使用时，需下载并安装后才能进行指标监控。操作包括下载、解压、配置，以及启动本地客户端等步骤。

       6. 定时任务jar包定义优化

       定时任务jar包已整合至扩展jar包中，新增定时任务时系统会自动加载。用户也可提前手动添加，确保定时任务与项目部署包一同打包。

       通过这些优化，系统响应速度得到显著提升，操作流程更加高效便捷。有兴趣的用户可申请免费试用体验。

       SoFlu软件机器人，作为全球首款针对微服务架构的软件机器人，革新了传统编码作业模式，通过可视化拖拽与参数配置实现复杂业务逻辑，一人全栈解决后端、前端、测试、运维等各类工作需求，大幅度降低软件开发门槛，显著提升企业软件开发效率与生产力。

       通过引入自动化、pyonth小游戏源码标准化与工具化流程，SoFlu软件机器人解决了传统软件开发过程中的依赖人工、成本高昂、技术选型难等问题，突破了被国外开发工具“卡脖子”的技术壁垒，为企业软件开发带来了十倍效率提升。

Matrix卡顿优化之IdleHandlerLagTracer源码分析

       IdleHandler是Android系统提供的一种机制，用于在消息队列空闲时执行任务，其任务优先级低于主线程，适用于实时性要求不高的任务。通常用于优化Android应用启动速度。然而，matrix卡顿优化中对IdleHandler进行监控的原因在于，IdleHandler属于主线程卡顿监控的关键环节。当IdleHandler中出现耗时任务执行，会明显导致主线程卡顿。

       为了进行性能优化，matrix对IdleHandler进行监控变得必要。IdleHandler监控的关键在于在TracePlugin中进行初始化和调用。构造方法仅接收配置，包含IdleHandler监控开关。onStartTrace方法调用onAlive方法，初始化HandlerThread，创建IdleHandlerLagRunnable，并启动检测IdleHandler的执行。

       IdleHandlerLagRunnable负责上报信息。detectIdleHandler方法通过反射获取mIdleHandlers列表，并通过MyArrayList实现hook点，监控IdleHandler的添加和移除。当消息队列添加IdleHandler时，MyArrayList的add方法将IdleHandler包装为MyIdleHandler存入，拦截queueIdle方法调用。

       MyIdleHandler继承自IdleHandler，重写queueIdle方法，监控IdleHandler执行过程。当IdleHandler执行时，idleHandlerLagHandler发送延时消息到子线程。若2s内未完成，收集信息上报，发现IdleHandler导致的卡顿问题。

       IdleHandlerLagTracer通过hook替换消息队列的IdleHandlers集合，拦截添加和移除逻辑，为原IdleHandler添加代理，监控queueIdle方法执行。超时未执行完成则收集信息上报，有效发现IdleHandler导致的卡顿。

       性能优化是Android开发中重要的一环，掌握IdleHandler监控机制有助于更细致地进行性能调优。此外，推荐关注Android学习资源，涵盖性能优化、框架底层原理、车载开发、逆向安全、音视频技术、Jetpack全家桶、OkHttp源码解析、Kotlin、Gradle、Flutter等多领域内容，助力深入学习和提升技术能力。

       Android性能优化、框架底层原理、车载开发、逆向安全、音视频技术、Jetpack全家桶、OkHttp源码解析、Kotlin、Gradle、Flutter等学习资源，助力深化技术理解与应用。

利用Cython加速计算密集型python任务

       计算密集型任务的特点是需要进行大量计算，主要消耗CPU资源，如计算圆周率、高清视频解码等。此类任务使用多任务可以完成，但任务越多，任务切换时间增加，CPU效率降低，理想情况应使任务数等于CPU核心数。Python脚本语言效率较低，不适于执行计算密集型任务。相比之下，C语言是编译型语言，通过编译器一次性将源代码转换成机器码，执行时无需再次编译，因此运行效率更高，程序可脱离语言环境独立运行。

       尽管Cython可以将Python+C混合编码转换为C代码，以优化Python脚本性能或调用C函数库，但这仍然无法与C语言相比。Python语言简洁、易读、可扩展，广泛应用于Web开发、科学计算、统计、人工智能等领域。然而，对于计算密集型任务，Python性能不足。如何在选择Python的情况下提高其运行效率？多进程方法较为常见，Cython便是提升效率的一种手段。

       Cython是一种让Python脚本支持C语言扩展的编译器。它能够将Python+C混合编码的.pyx脚本转换为C代码，用于优化Python脚本性能或调用C函数库。Cython是提高Python性能的常用方法之一。

       以计算万以内的素数列表为例，使用Cython优化代码。首先，使用纯Python实现，然后尝试直接使用Cython将其编译为C代码。结果表明，程序执行速度有轻微提升。进一步深入代码，利用Cython分析生成的代码以识别可以优化的部分。通过指定Python数据类型，如将参数n和循环变量i、j定义为int类型，可以减少调用Python虚拟机的次数，从而显著提高程序效率。最终，经过微小的改动，程序运行速度提高了.%，比纯Python版本快了约倍。

       程序的优化还可以进一步探索，如使用numpy.array替代原生列表。Python性能提升工具还包括Shed Skin、Numba、Pythran、PyPy等，它们可以从不同角度提高Python程序的运行效率。然而，选择合适的工具和优化策略，针对具体业务制定高效方案才是关键。

       总结来看，尽管Python语言在某些领域具有独特优势，但在计算密集型任务中性能不足。Cython等工具可以帮助提升Python程序的运行效率，但实际性能仍可能无法与C语言相比。在选择使用Python时，结合特定的优化策略和技术工具，可以有效提高程序性能。

       特别说明的是，Python的动态类型特性导致运行时效率相对较低。Cython通过指定数据类型可以减少Python虚拟机的调用，显著提升程序性能。在优化代码时，应关注循环体内的计算，尽可能减少调用Python虚拟机的次数，从而提高效率。

       尽管Cython等工具能够优化Python程序的运行效率，但关键在于根据具体业务需求制定高效解决方案。《Python高性能编程》等书籍可以为Python性能优化提供更深入的了解和指导。