Java线程–优雅关闭
笔记 / 2018年10月13日

不建议用stop 操作, 比较粗鲁, 会导致其可能的一些锁被粗暴的释放,导致一些场景下的数据不一致;   样例1 :interrupt方法 public class ThreadStopGraceful1 implements Runnable { public void run() { while(true) { if (Thread.currentThread().isInterru…

java 多线程锁机制1–Synchrnized
笔记 / 2018年10月12日

原子性(Atomicity) 原子性是指在一个操作中就是cpu不可以在中途暂停然后再调度,既不被中断操作,要不执行完成,要不就不执行。如果一个操作时原子性的,那么多线程并发的情况下,就不会出现线程安全问题; 例如a++,对于共享变量a的操作,实际上会执行三个步骤, 1.读取变量a的值到寄存器 2.寄存器中的值+1 3.将值赋予变量a 这三个操作中任何一个操作过程中,a的值被人篡改,那么都会出现我们…

flink&spark stream 实践–在线LR模型训练与预测
未分类 , 笔记 / 2018年4月30日

项目目的: 和《flink实践–datastream-taxi到达目的地时间预测》章节一样,目的还是利用实时获取taxi行车轨迹数据,实时数据经过处理和提取特征过程,特征数据再实时被用于模型在线训练模型,用于实时预测taxi 到达目的地的时间, 只不不过实现方式稍微不同,由于flink的ML库不是很成熟, 新方案试着使用flink  实现特征提取 dataStream, 通过Kafka…

flink实践–家用电器用电消耗分析&预测
笔记 / 2018年4月25日

项目目标: 对家用电器电量消耗数据做分析和多种模型的预测 a. 实时提取部分特征用于预测家用用电和季节的关系 b.提取部分特征用于聚类分析—根据用电量特征做聚类 c. 还可以使用Spark离线机器学习做复杂的预测   数据集(离线)分析: household_power_consumption数据维度信息: 1.date: 日期,格式为 dd/mm/yyyy 2.time: …