• 2024-07-03springboot线程池简单配置
    @ConfigurationpublicclassThirdPartyOilSmallTaskConfig{@Bean("thirdPartyOilSmallTaskExecutor")publicThreadPoolTaskExecutoruniteOilThreadPoolTaskExecutor(){ThreadPoolTaskExecutorexecutor=newThreadPoolTaskExecutor();
  • 2024-07-02springboot实现异步调用demo
    springboot实现异步调用异步调用特点异步调用在开发程序中被广泛应用,在异步任务中,主线程不需要阻塞等待异步任务的完成,而是可以继续处理其他请求。异步调用的特点如下:非阻塞:主线程在调用异步方法后不会等待其完成,而是立即返回。后台处理:耗时操作在后台独立的线程中执行,不会
  • 2024-07-01spring 定时任务 使用线程池
    spring线程池定义packagecom.minex.icp.tool.conf;importlombok.extern.slf4j.Slf4j;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.scheduling.annotation.AsyncConfi
  • 2024-06-24'MMDetection3D'+'waymo-open-dataset-tf-2-6-0'+'pytorc2.3.1+cu121'安装
    安装pytorc2.3.1+cu121步骤1.创建并激活一个conda环境condacreate-nmmdpython=3.8-ycondaactivatemmd步骤2.基于PyTorch官方说明安装PyTorch,例如:pip3installtorchtorchvisiontorchaudio--index-urlhttps://download.pytorch.org/whl/cu121步骤3.验
  • 2024-06-23MyBatis 源码分析--获取SqlSession
    前言:前文我们从源码层面梳理了SqlSessionFactory的创建过程,本篇我们继续分析一下SqlSession的获取过程。初识MyBatis【MyBatis核心概念】MyBatis源码分析–SqlSessionFactory案例代码:publicclassMyBatisTest{@Testpublicvoidtest()throwsIOEx
  • 2024-06-22Nacos+@RefreshScope使用场景
    Nacos+@RefreshScope使用场景线程池配置动态刷新yaml配置此配置在Nacos配置中心spring:task:execution:pool:core-size:30max-size:100queue-capacity:0thread-name-prefix:async-task-java配置类@RefreshScope放
  • 2024-06-22视频通话源码,使用线程池的两大要点分析
    视频通话源码,使用线程池的两大要点分析:1、实现动态调整线程池参数2、对线程池运行情况进行监控一,线程池可调整的参数1、核心线程数2、超时时间3、最大线程数4、拒绝策略 而队列BlockingQueue因为是final类型,所以没有对外修改入口。但可以通过重写LinkedBlockingQueue
  • 2024-06-21带你学习Mybatis之拦截器
    mybatis拦截器mybatis拦截器也叫做插件,mybatis允许开发者自定义拦截器对SQL语句执行过程中的某一个点进行拦截。默认mybatis允许拦截Mybatis中的四大核心对象:Executor中的方法、ParameterHandler的方法、ResultSetHandler的方法以及StatementHandler中的方法Executor
  • 2024-06-21记录一次代码中的ForkJoinPool.getCommonPoolParallelism()
    @Configuration@Slf4jpublicclassThreadPoolConfig{privatestaticfinalintCORE_POOL_SIZE=6;privatestaticfinalintMAX_POOL_SIZE=12;privatestaticfinalintKEEP_ALIVE_TIME=60;privatestaticfinalintQUEUE_CAPACITY=
  • 2024-06-19ETL可视化工具 DataX -- DataX-Web安装 (三)
    引言DataX系列文章:ETL可视化工具DataX–简介(一)ETL可视化工具DataX–安装部署(二)3.1简介DataXWeb是在DataX之上开发的分布式数据同步工具,提供简单易用的操作界面,降低用户使用DataX的学习成本,缩短任务配置时间,避免配置过程中出错。用户可通过页面选
  • 2024-06-17浅析Mybatis拦截器
    一、背景最近针对项目中出现的慢sql,我们使用自定义Mybatis拦截器,结合DUCC动态配置慢sql阈值,来监控慢sql并报警,提前发现风险点。借着这个契机,浅析下Mybatis拦截器原理,个人理解,不足之处请指正。二、Mybatis拦截器Mybatis使用plugin来拦截方法调用,所以MyBatisplugin也称为:Mybatis
  • 2024-06-16带你学习Mybatis之执行器Executor
    执行器ExecutorExecutor定义了数据库操作的基本方法,SqlSession接口中的功能都是基于Executor接口实现的,真正执行java和数据库交互的类,负责维护一级缓存和二级缓存,并提供事务管理的相关操作,会将数据库相关操作委托给StatementHandler完成public enum ExecutorType { 
  • 2024-06-14XXL-job 使用
    1、找到XXL-job官网去下代码https://github.com/xuxueli/xxl-job2、下载下来用IDEA打开,你会得到这样子的目录结构3、打开doc目录下面有个db,在你数据库里面创建对应的数据库4、运行服务端xxl-job-admin登录进去账号admin密码123456好了,现在我们服务端启动好了5、创建
  • 2024-06-08快速使用 ThreadPoolExecutor 并行加速
    总览一般的Python脚本只会用上单线程。对于IO密集型任务,用多线程加速会快得多。本文会给出一个模板,使用ThreadPoolExecutor进行并行加速。注意,由于GIL的存在,对于CPU密集型任务ProcessPoolExecutor是更好的选择。快速使用ThreadPoolExecutor请看以下模板。fro
  • 2024-06-07springboot-异步使用
    创建配置类,开启异步和创建线程packagecom.chulx.demo1.config;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.scheduling.annotation.EnableAsync;importorg.springframe
  • 2024-06-05Python并发 :ThreadPoolExecutor
    concurrent.futures是Python中执行异步编程的重要工具,它提供了以下两个类: 1.ThreadPoolExecutorfromconcurrent.futuresimportThreadPoolExecutordeftest(num):print("Threads"num)#新建ThreadPoolExecutor对象并指定最大的线程数量withThreadPoolExecutor(
  • 2024-05-31Spring的@Async注解及其用途
    Spring的@Async注解是SpringFramework4.2版本引入的功能,它用于支持异步方法执行。当一个方法标注了@Async,Spring会在一个单独的线程中调用该方法,从而不会阻塞主线程的执行。@Async注解的用途:提高性能:通过异步执行,可以提高应用程序的响应性能,特别是在执行耗时的
  • 2024-05-25Java ThreadPoolExecutor
    ThreadPoolExecutor?ThreadPoolExecutor是什么,先拆开来看,ThreadPoolAndExecutor?那ThreadPool是什么?Executor又是什么?Executor:任务执行者,只定义了一个execute方法,接收一个Runable参数。publicinterfaceExecutor{voidexecute(Runnablecommand);}ThreadPool:可以缓存
  • 2024-05-25datax和datax-web时间问题处理(定时任务没有按指定时间触发、日志时间错误)
    datax-web和datax各种时间不准问题此文目的为解决日志输出中的时间不准确问题和datax-web定时任务触发时间不对的问题(以东八区为例),但首先要确认操作系统的时间和时区是正常的!!!。总体思路就是修改时区,修改三个文件:datax.py、datax-executor.sh、datax-admin.sh在对应的位置加上时
  • 2024-05-24原子、组合与汇编
    应用程序里可以任意写SQL语句,到了数据库这层,所有的SQL语句都被做了编排。在应用层可以同步、异步的投递SQL语句:s1,s2,s3,...。混在意大利面条一样的代码里,看不到谁先执行谁后执行。在数据库层,这些语句会被编排。编排后,实际的执行时序可能是s2,25,s1,s3,s4...那么数据库层面
  • 2024-05-24原子、组合与汇编
    应用程序里可以任意写SQL语句,到了数据库这层,所有的SQL语句都被做了编排。在应用层可以同步、异步的投递SQL语句:s1,s2,s3,...。混在意大利面条一样的代码里,看不到谁先执行谁后执行。在数据库层,这些语句会被编排。编排后,实际的执行时序可能是s2,25,s1,s3,s4...那么数据库层面
  • 2024-05-24XXL-JOB executor 未授权访问漏洞
    XXL-JOBexecutor未授权访问漏洞XXL-JOB是一个分布式任务调度平台,其核心设计目标是开放迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线,开箱即用。XXL-JOB分为admin和executor两端,前者为后台管理页面,后者是任务执行的客户端。executor默认没有配置认证
  • 2024-05-19【Mybatis/Mybaits-Plus】【插件】插件执行时机
    1 前言我之前看过插件的执行过程:【Mybatis】【插件】Mybatis源码解析-插件机制,主要是通过一个 Executor的创建以及执行过程串了一下插件,我们这里简单回忆下:(1)Mybatis把所有的插件都放进了 InterceptorChain类里的 interceptors集合里(2)插件的两个时机:入场时机:插件是在
  • 2024-05-16spark-submit 提交的参数
    spark-submit是用于提交Spark应用到集群的命令行工具。它允许用户控制Spark应用的各种参数,比如应用名、集群URL、运行模式、资源分配等。以下是一些常用的spark-submit参数:--master:指定Spark集群的URL,例如local,local[*],spark://23.195.26.187:7077,yarn,mesos等。--d
  • 2024-05-09spark简介
    一、Spark简介Spark是一种由Scala语言开发的快速、通用、可扩展的大数据分析引擎。Spark主要由五部分组成:SparkCoreSparkCore中提供了Spark最基础与最核心的功能,Spark其他的功能如:SparkSQL,SparkStreaming,GraphX,MLlib都是在SparkCore的基础上进行扩展的S