1、JedisConnectionPool.scala package sparkstreaming import redis.clients.jedis.{Jedis, JedisPool, JedisPoolConfig} object JedisConnectionPool{ val conf ...
分类：
其他好文 时间：
2020-08-07 18:03:42
阅读次数：
62
ThreadPoolExecutor executor = new ThreadPoolExecutor(2, //核心线程数 5,//最大线程数 60L, //临时线程空闲时间 TimeUnit.SECONDS,//时间单位 new ArrayBlockingQueue<Runnable>(25) ...
分类：
编程语言 时间：
2020-08-06 17:06:28
阅读次数：
85
类的结构： Executor-ExecutorService--AbstractExecutorService ThreadPoolExecutor ThreadPoolExecutor七大构造参数： package com.dwz.executors; import java.util.concu ...
分类：
其他好文 时间：
2020-08-05 10:39:42
阅读次数：
89
TensorFlow 是一个端到端开源机器学习平台 安装 pip3 install tensorflow 使用时报错如下 2020-06-03 09:42:51.737502: W tensorflow/stream_executor/platform/default/dso_loader.cc:5 ...
分类：
其他好文 时间：
2020-08-05 10:33:08
阅读次数：
111
长按二维码，关注我们项目在重新发布的过程中，如果有的请求时间比较长，还没执行完成，此时重启的话就会导致请求中断，影响业务功能，优雅重启可以保证在停止的时候，不接收外部的新的请求，等待未完成的请求执行完成，这样可以保证数据的完整性。SpringBoot1.Ximportjava.util.concurrent.Executor;importjava.util.concurrent.ThreadPoo
分类：
编程语言 时间：
2020-08-03 23:20:45
阅读次数：
70
多线程 创建线程的两种方式 1.继承Thread类，重写它的run方法； 2.实现Runnable接口，重写它的run方法； 延时睡眠 sleep(延时)使线程休眠不会释放锁 线程终止 定义一个标志位flag=false,不推荐使用stop（），destroy()方法 线程强制执行 join,可以想 ...
分类：
编程语言 时间：
2020-07-30 10:47:15
阅读次数：
77
#1 系列目录 线程池接口分析以及FutureTask设计实现 线程池源码分析-ThreadPoolExecutor 该系列打算从一个最简单的Executor执行器开始一步一步扩展到ThreadPoolExecutor，希望能粗略的描述出线程池的各个实现细节。针对JDK1.7中的线程池 #2 Thr ...
分类：
编程语言 时间：
2020-07-30 01:12:34
阅读次数：
69
#1 系列目录 线程池接口分析以及FutureTask设计实现 线程池源码分析-ThreadPoolExecutor 该系列打算从一个最简单的Executor执行器开始一步一步扩展到ThreadPoolExecutor，希望能粗略的描述出线程池的各个实现细节。针对JDK1.7中的线程池 #2 Exe ...
分类：
编程语言 时间：
2020-07-30 01:11:37
阅读次数：
72
Spark的架构图 1、RDD(弹性分布式数据集) RDD是对象的分布式集合。 RDD以并行方式应用和记录数据转换 RDD也提供数据沿袭——以图形形式给出每个中间步骤的祖先树，当RDD的一个分区丢失，可以根据祖先树重建该分区。 RDD有两组操作，转换(transformation)和行动(actio ...
分类：
其他好文 时间：
2020-07-28 22:37:30
阅读次数：
72
