import org.apache.spark.SparkConfimport org.apache.spark.streaming.{Seconds, StreamingContext}// 创建一个本地模式的StreamingContext, 两个工作线程， 1s的批处理间隔//Master要求 ...
分类：
其他好文 时间：
2021-07-02 16:32:11
阅读次数：
0
进程：一个程序的执行实例。对操作系统来说：一个任务就是一个进程。 线程：一个进程内往往同时运行着多个子任务，这些子任务就是线程。线程是操作系统能够进行运算调度的最小单位。 一个进程至少有一个线程，一个进程也可以并发多个线程，这些线程可以并行执行不同的任务。一个进程在启动时会先产生一个线程，这个线程被 ...
分类：
编程语言 时间：
2021-07-02 15:54:52
阅读次数：
0
作者：rickiyang 出处：www.cnblogs.com/rickiyang/p/11074231.html 我们知道在TCP长连接或者WebSocket长连接中一般我们都会使用心跳机制–即发送特殊的数据包来通告对方自己的业务还没有办完，不要关闭链接。 那么心跳机制可以用来做什么呢？ 我们知道 ...
分类：
Web程序 时间：
2021-06-13 09:48:57
阅读次数：
0
对于一些活动相关的业务场景，如果设置了到时间开启，可以通过自己实现延时队列的方式来完成类似业务。如添加完活动用活动开启时间减去当前时间，去创建延时任务，再将其添加到延时队列中，以此来完成到时间活动自动开启关闭的功能，当然这种方式只适用于单体架构，如果是集群或分布式，需要自行加分布式锁或利用redis ...
分类：
编程语言 时间：
2021-06-11 18:26:12
阅读次数：
0
CancellationTokenSource 一、代码案例 代码： class Program { private static int TaskMethod(string name, int seconds, CancellationToken token) { Console.WriteLin ...
分类：
其他好文 时间：
2021-06-07 21:14:09
阅读次数：
0
Redis常用存储类型 Redis底层提供了5种数据结构：字符串、哈希、列表、集合、有序集合 下图非常形象的表示了数据结构： 字符串String 常用命令 EX seconds：设置失效时长，单位秒 PX milliseconds：设置失效时长，单位毫秒 NX：key不存在时设置value，成功返回 ...
分类：
其他好文 时间：
2021-05-24 06:52:11
阅读次数：
0
#include <chrono> /// nanoseconds typedef duration<_GLIBCXX_CHRONO_INT64_T, nano> nanoseconds; /// microseconds typedef duration<_GLIBCXX_CHRONO_INT64 ...
分类：
编程语言 时间：
2021-05-24 06:07:05
阅读次数：
0
当使用PProf不是太详细的时候就可以使用 trace来查看跟踪了 这个命令可以配合PProf 先把trace文件下载下来 curl http://域名/debug/pprof/trace?seconds=20 > trace.out 使用 go tool trace C:\Users\shihan ...
分类：
其他好文 时间：
2021-05-24 04:10:43
阅读次数：
0
package com.atguigu.boot.com.atguigu; import java.io.IOException; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Lock; import ...
分类：
其他好文 时间：
2021-05-03 11:52:44
阅读次数：
0
vi no_interaction_script1.sh #!/bin/bash #提示用户该脚本3秒后退出echo "This script will quit after 3 seconds. " #计时3s sleep 1echo -n "."sleep 1echo -n "."sleep 1 ...
分类：
系统相关 时间：
2021-04-13 12:16:49
阅读次数：
0
