线程池为线程生命周期的开销和资源不足问题提供了解决方 案。通过对多个任务重用线程，线程创建的开销被分摊到了多个任务上。 线程实现方式 Thread、Runnable、Callable 注意：启动Thread线程只能用start（JNI方法）来启动，start方法通知虚拟机，虚拟机通过调用器映射到底层 ...
分类：
编程语言 时间：
2019-08-21 09:33:38
阅读次数：
159
目前刚入职了一家公司，要求替换当前系统（单体应用）以满足每日十万单量和一定系统用户负载以及保证开发质量和效率。由我来设计一套基础架构和建设基础开发测试运维环境，github地址。 出于本公司开发现状及成本考虑，我摒弃了市面上流行的Spring Cloud以及Dubbo分布式基础架构，舍弃了集群的设计 ...
分类：
编程语言 时间：
2019-08-20 12:33:29
阅读次数：
94
步骤： 创建线程池对象创建 Runnable 接口子类对象提交 Runnable 接口子类对象关闭线程池实例： class TaskRunnable implements Runnable{ @Override public void run() { for (int i = 0; i < 10; ...
分类：
编程语言 时间：
2019-08-15 19:23:36
阅读次数：
90
一、基于Receiver的方式1、概述基于Receiver的方式：Receiver是使用Kafka的高层次Consumer API来实现的。receiver从Kafka中获取的数据都是存储在Spark Executor的内存中的，然后Spark Streaming启动的job会去处理那些数据。然而，... ...
分类：
其他好文 时间：
2019-08-13 15:41:08
阅读次数：
99
一、前言 在项目中经常有一些场景会连续发送多个请求，而异步会导致最后得到的结果不是我们想要的，并且对性能也有非常大的影响。例如一个搜索框，每输入一个字符都要发送一次请求，但输入过快的时候其实前面的请求并没有必要真的发送出去，这时候就需要在发送新请求的时候直接取消上一次请求。vue axios拦截器介 ...
分类：
移动开发 时间：
2019-08-13 12:05:47
阅读次数：
209
可以通过全局配置文件指定默认的Executor开启批量处理模式： 如果在全局配置文件中指定的话BATCH模式的话，所有的其他不需要批量处理的sql,都默认使用了Batch模式，所以正常情况下在应该在获取sqlSession的时候指定使用Batch类型的Executor，而不应该在全局配置文件配置： ...
分类：
其他好文 时间：
2019-08-11 17:38:21
阅读次数：
75
设计模式：命令模式 重点： 传递命令，执行器执行命令。 线程类：Executor 就是使用的命令模式。 源码： public interface Executor { void execute(Runnable command); } 额外的话题： 线程工厂的意义： 解耦 原有的创建线程方式：创建线 ...
分类：
其他好文 时间：
2019-08-10 09:21:19
阅读次数：
84
从JDK1.5开始有的并发库，给JAVA线程的管理和使用提供了强大的便利性。 java.util.current包中提供了对线程优化、管理的各项操作，使得线程的使用变得得心应手， 该包提供了线程的运行，线程池的创建，线程生命周期的控制。 java通过Executors提供了四种静态方法创建线程池，分 ...
分类：
编程语言 时间：
2019-08-06 19:49:40
阅读次数：
91
关于线程池的几个参数，很多人不是很清楚如何配置，他们之间是什么关系，我用代码来证明一下。 输出结果，观察关系： //任务数 a = 3 , 活跃线程数3 , 任务数 < 核心线程数。 //任务数 a = 4 , 活跃线程数4 , 任务数 < 核心线程数。 //任务数 a = 5 , 活跃线程数5 , ...
分类：
编程语言 时间：
2019-08-06 00:26:40
阅读次数：
155
Streaming 统计来自 kafka 的数据，这里涉及到的比较，kafka 的数据是使用从 flume 获取到的，这里相当于一个小的案例。 1. 启动 kafka 2. 启动 flume flume 配置文件如下 这里 flume 是的数据是来自一个文件，只要这个文件有数据进入，就会被flume ...
分类：
其他好文 时间：
2019-07-28 19:55:02
阅读次数：
110
