标签：rsync

wenming.gapo 发布于 2020-04-07

概述 在jdk中内置了可重入锁 synchronized 来维护代码的同步，但是 synchronized 是在虚拟机层面实现，并且功能比较少，难以满足一些特殊的情况，所以在 concurrency 包中就有了类似的方法 ReentrantLock 。今天我们就一起来分析下 Re...

阅读(10)评论(0)赞 (0)标签：final / http / https / id / IO / java / queue / rsync / stream / synchronized / UI / 代码 / 同步 / 总结 / 源码 / 线程 / 锁 / 需求

xiaoli.wang 发布于 2020-03-30

使用场景：用于 有且仅有两个线程 间的 数据传输，就就是线程间的 通信 。它是 生产者/消费者 d的 wait() / notify() 的最佳替代工具。 核心原理：方法 exchange()阻塞特性：此方法被调用后等待其他线程来取数据，如果没有其他线程取得数据，则一直 阻塞。 ...

阅读(19)评论(0)赞 (0)标签：ACE / cat / CountDownLatch / CyclicBarrier / final / http / https / id / IDE / IO / map / queue / rmi / rsync / Semaphore / tar / UI / volatile / 代码 / 同步 / 并发 / 数据 / 本质 / 线程 / 锁

xiaoli.wang 发布于 2020-03-28

pipeline { agent { label 'my-blog' # 因为我的博客服务器已经搭建了node环境，所以就用他来构建啦 } stages { stage('build') { steps { sh './build.sh' } } stage('deploy') ...

阅读(28)评论(0)赞 (0)标签：Agent / build / CTO / ECS / http / https / IO / ip / message / node / REST / root / rsync / tag / tar / UI / web / 代码 / 博客 / 备份 / 服务器 / 端口 / 进程 / 配置

刘莉莉 发布于 2020-03-21

java中使用Semaphore构建阻塞对象池 Semaphore是java 5中引入的概念，叫做计数信号量。主要用来控制同时访问某个特定资源的访问数量或者执行某个操作的数量。 Semaphore中定义了一组虚拟的permits，通过获取和释放这些permits，Semaphor...

阅读(28)评论(0)赞 (0)标签：Collection / Collections / final / git / GitHub / HashSet / http / https / id / IO / java / map / Master / rmi / rsync / Semaphore / synchronized / UI / 数据 / 数据库 / 连接池

darida 发布于 2020-03-19

问题 请求被限流 之前的文章提到过我们服务使用 Hystrix 进行服务限流，使用的是信号量方式，并根据接口的响应时间和服务的峰值 QPS 设置了限流的配额。 限流配额的计算方式为： 我们接口单机单个接口的峰值 QPS 为 1000，平均影响时长 15ms，我们认为 Hystri...

阅读(26)评论(0)赞 (0)标签：API / App / bug / cat / ECS / git / GitHub / HTML / http / https / Hystrix / id / IDE / IO / java / js / jstack / JVM / key / map / message / QPS / queue / rmi / rsync / Semaphore / UI / 代码 / 博客 / 压力 / 并发 / 微博 / 文章 / 时间 / 源码 / 线程 / 线程池 / 部署 / 配置 / 限流

zhuangli 发布于 2020-03-17

public class Semaphore implements java.io.Serializable 复制代码 2. 字段属性 //序列化版本号 private static final long serialVersionUID = -32225786616006802...

阅读(22)评论(0)赞 (0)标签：CEO / Collection / final / http / https / id / IO / java / map / queue / rmi / rsync / Semaphore / UI / zab / 代码 / 同步 / 时间 / 构造方法 / 线程 / 设计模式 / 锁

刘莉莉 发布于 2020-03-16

ReentrantLock 是一种可重入锁，可重入是说同一个线程可以多次获取同一个锁，内部会有相应的字段记录重入次数，它同时也是一把互斥锁，意味着同时只有一个线程能获取到可重入锁。 1.构造函数 public ReentrantLock() { sync = new Nonfai...

阅读(25)评论(0)赞 (0)标签：ConcurrentHashMap / CountDownLatch / final / HashMap / HTML / http / id / IO / ip / map / node / ORM / queue / rsync / synchronized / UI / 代码 / 删除 / 博客 / 参数 / 垃圾回收 / 多线程 / 总结 / 源码 / 线程 / 锁

xiaoli.wang 发布于 2020-03-12

Semaphore（信号量）用来限制访问同一资源的线程数量。它通过初始化一个固定数量的配额，当线程要执行时，必须先获取配额才能继续执行，当获取不到时，就需要挂起等待；持有配额的线程执行完后需释放配额，并唤醒等待的线程。 使用方法 public class SemaphoreDem...

阅读(18)评论(0)赞 (0)标签：ACE / cat / final / http / https / id / IO / map / node / ORM / queue / rmi / rsync / Semaphore / tar / UI / 代码 / 同步 / 构造方法 / 源码 / 线程 / 锁

yeseng 发布于 2020-03-11

Rlock在构造的时候传入一个标记是否为fair的boolean，表示该锁在释放的时候是否偏向将权限交给等待时间最长的线程，否则对获取锁的顺序不做任何保证。公平锁会带来很大的性能损耗，但是优点是获取锁的时间方差较小，而且不会有饿死的风险. 调用Rlock的tryLock()方法的...

阅读(17)评论(0)赞 (0)标签：Action / App / ask / cat / CountDownLatch / CyclicBarrier / final / find / http / https / id / IO / ip / map / node / ORM / queue / retry / rmi / rsync / Semaphore / synchronized / UI / update / 一致性 / 代码 / 同步 / 定制 / 并发 / 时间 / 线程 / 锁