本文重点讲解当线程池的任务过多时，如何去拒绝这些任务。 拒绝条件 1.线程已经shutdown了，需要拒绝 2.最大线程数或者队列已经满了，需要拒绝 拒绝策略 1.abortPolicy: 直接抛出异常 2.discardPolicy:任务丢弃，收不到通知 3.discardOldestPolicy ...
分类：
编程语言 时间：
2020-04-21 15:20:26
阅读次数：
109
本文介绍下Java中线程池的基本用法，基于此说明如何去确定线程池的大小。 线程池的创建方法 newFixedThreadPool 创建固定线程数的线程池，见下创建代码 /** * Creates a thread pool that reuses a fixed number of threads ...
分类：
编程语言 时间：
2020-04-21 13:34:00
阅读次数：
82
介绍: Hystrix的请求合并就是把重复的请求批量的用一个HystrixCommand命令去执行，以减少通信消耗和线程数的占用。Hystrix的请求合并用到了HystrixCollapser这个抽象类，它在HystrixCommand之前前放置一个合并处理器，将处于一个很短的时间窗(默认10ms) ...
分类：
编程语言 时间：
2020-04-20 23:20:53
阅读次数：
91
配置一： server:# tomcat 配置 tomcat: # 接收队列长度 accept-count: 1000 # 最小空闲线程数 min-spare-threads: 100 # POST请求提交大小 max-http-form-post-size: 50MB # 最大链接数 max-co ...
分类：
编程语言 时间：
2020-04-19 18:05:07
阅读次数：
99
[TOC] Semaphore、SemaphoreSlim 类 两者都可以限制同时访问某一资源或资源池的线程数。 这里先不扯理论，我们从案例入手，通过示例代码，慢慢深入了解。 Semaphore 类 这里，先列出 Semaphore 类常用的 API。 其构造函数如下： | 构造函数 | 说明 | ...
分类：
编程语言 时间：
2020-04-18 22:33:33
阅读次数：
81
20200413碰到一个新问题，tomcat运行正常，上传数据很缓慢，或者数据丢失。 检查网络正常，检查数据库正常，也不卡顿，就是上传数据到数据库的时候很卡顿。 maxThreads="1000" 最大并发数 minSpareThreads="100"///初始化时创建的线程数 maxSpareTh ...
分类：
Web程序 时间：
2020-04-13 19:28:06
阅读次数：
121
在项目中经常使用到多线程来提升业务处理速度，但线程池的大小该定义为多大，这块该怎么确定？1.IO密集型单核心最佳线程数=1+(IO耗时/CPU耗时)多核心线程数星佳线程数=CPU核数*(1+(IO耗时/CPU耗时))注：如何获取CPU耗时和IO耗时，可以通过APM之类系统2.CPU密集型最佳线程数=CPU核数+1说明一下这个1哪来的，是为了防止突然有线程出现内存页失效或者其它原因导致阻塞；3.总结
分类：
编程语言 时间：
2020-04-12 00:07:15
阅读次数：
113
Flink运行模式分为：集群模式、单机模式 集群模式：Flink的并行度取决于配置文件中的默认值,如下如所示： 在此配置的默认值下，全局的所有算子平行度都是1，我们也可以在程序中重写这个并行度 设置方式如下： 在本地模式下：默认的并行度为CPU核数可以执行线程数的最大值。比如：一台 8核 16线程的 ...
分类：
其他好文 时间：
2020-04-11 18:11:57
阅读次数：
140
今天三个部分的知识、递归锁（解决同步锁造成的锁死现象）、同步对象（类似一个锁，使两个线程之间进行同步）、信号量（控制线程数量的一个锁），悄悄的说一下，算上昨天的同步锁，虽然已经讲了四种锁了，但是据说总共是有五种锁的，最后一个我还不知道是个啥。 一、递归锁 昨天引入了同步锁的概念，但是因为同步锁的引入 ...
分类：
编程语言 时间：
2020-04-10 00:19:10
阅读次数：
59
概论 线程池（英语：thread pool）：一种线程使用模式。线程过多会带来调度开销，进而影响缓存局部性和整体性能。而线程池维护着多个线程，等待着监督管理者分配可并发执行的任务。这避免了在处理短时间任务时创建与销毁线程的代价。线程池不仅能够保证内核的充分利用，还能防止过分调度。可用线程数量应该取决 ...
分类：
其他好文 时间：
2020-04-07 23:56:24
阅读次数：
125
