17 天前 / 肖奈
PhotoBy Instagramjuig.yyn 上期问题 少年，老衲看你骨骼清奇，眉宇之间透露着一股王者的气息。来吧，跟我讲讲 ConcurrentHashMap 是如何进行管理它的容量的，也就是当我们调用它的 size 方法的时候发生了什么故事？（前面我们介绍了 ConcurrentHashMap 的实现原理，但是扩容和容量大小留了个小尾巴，今天来割一下这个小尾巴，嘿嘿） 我的答案 毕竟是要支持并发，ConcurrentHashMap 的扩容操作比较复杂，我们将从以下几点来带讨论一下它的扩容。 触发扩容1. 添加新元素后，元素个数达到扩容阈值触发扩容。 2. 调用 p......
19 天前 / Ccww
欢迎关注公众号【Ccww笔记】，原创技术文章第一时间推出往期文章： 《提升能力，涨薪可待》-Java并发之AQS全面详java多线程并发系列--基础知识点（笔试、面试必备）《提升能力，涨薪可待》—Java并发之Synchronized...ThreadLocal1. ThreadLocal是什么？使用场景ThreadLocal简介ThreadLocal是线程本地变量，可以为多线程的并发问题提供一种解决方式，当使用ThreadLocal维护变量时，ThreadLocal为每个使用该变量的线程提供独立的变量副本，所以每一个线程都可以独立地改变自己的副本，而不会影响其它线程所对应的副本。 ThreadLocal使用场景多个......
29 天前 / Ccww
欢迎关注公众号【Ccww笔记】，原创技术文章第一时间推出往期文章： 《提升能力，涨薪可待》-Java并发之AQS全面详java多线程并发系列--基础知识点（笔试、面试必备）... Synchronized简介 线程安全是并发编程中的至关重要的，造成线程安全问题的主要原因： 临界资源， 存在共享数据 多线程共同操作共享数据 而Java关键字synchronized，为多线程场景下防止临界资源访问冲突提供支持， 可以保证在同一时刻，只有一个线程可以执行某个方法或某个代码块操作共享数据。 即当要执行代码使用synchronized关键字时，它将检查锁是否可用，然后获取......
46 天前 / chauncy-ilife
预备知识 一 : 网络通信的一般形式 采用BIO 通信模型的服务端，通常由一个独立的 Acceptor 线程负责监听客户端的连接。我们一般通过在while(true)循环中服务端会调用accept()方法等待接收客户端的连接的方式监听请求，请求一旦接收到一个连接请求，就可以建立通信套接字在这个通信套接字上进行读写操作，此时不能再接收其他客户端连接请求，只能等待同当前连接的客户端的操作执行完成， 不过可以通过多线程来支持多个客户端的连接,每个客户端一个线程就是上图所示,但是这里有一个问题就是如果客户端的很多我们需要开启很多线程然后操作系统对线......
61 天前 / KIWI_
【并发那些事】可见性问题的万恶之源 硬件工程师为均衡 CPU 与 缓存之间的速度差异，特意加的 CPU 缓存，竟然在多核的场景下阴差阳错的成为了并发可见性问题的万恶之源！(本文过长，如果不是特别无聊，看到这里就可以了) 前言还记得那些年，你写的那些多线程 BUG 吗？明明只想得到个 1 + 1 = 2 的预期，结果他有时候得到 1，有时候得到 3，但偏偏有时候他也会返回正确的 2。明明在本地运行的好好的，一上线一堆诡异的 BUG。你一遍一遍的检查代码，一行一行 debug，结果无功而返。 变量为何突然变异？代码为何乱序运行？条件为何形同虚设？欢......
85 天前 / kk德米安
并发（并行），一直以来都是一个编程语言里的核心主题之一，也是被开发者关注最多的话题；Go语言作为一个出道以来就自带 『高并发』光环的富二代编程语言，它的并发（并行）编程肯定是值得开发者去探究的，而Go语言中的并发（并行）编程是经由goroutine实现的，goroutine是golang最重要的特性之一，具有使用成本低、消耗资源低、能效高等特点，官方宣称原生goroutine并发成千上万不成问题，于是它也成为Gopher们经常使用的特性。 Goroutine是优秀的，但不是完美的，在极大规模的高并发场景下，也可能会暴露出问题，什么问题呢？又有什么可选的解......
101 天前 / KIWI_
创建线程可以说是并发知识中最基础的操作了，JDK 提供的创建线程的方式，如果不包括通过线程池的话，目前有三种形式，它们分别是通过继承 Thread 类，通过实现 Runable 接口，通过 FutureTask。如下图所示 下面整理了一下 3 种方法的具体使用与异同。 创建线程的 3 种方法1. 继承 Thread创建一个类继承 Thread 并覆盖 run 方法 class MyThread extends Thread { @Override public void run() { String threadName = getName(); for (int i = 0; i { @Override public String call() throws ......
137 天前 / 风来风往风伤(TiAmo)
《并发扣款，如何保证数据的一致性？》一文的核心观点是：使用CAS乐观锁，在写回余额时加上旧余额的比对，可以在不影响吞吐量的前提下，保证余额的一致性。 文章非常多朋友留言问，能不能把余额放到reids里，利用redis的事务性来扣减余额。今天，就这个问题简单的说一下。 redis如何实现事务性？本质也是乐观锁。 在redis客户端执行：$money = GET key$money = $money - $diffSET key $money在并发量大的时候，会遇到和《并发扣款，如何保证数据的一致性？》中描述的并发一致性问题。 redis的WATCH和EXEC可以提供类似事务的机制：WATCH观......
142 天前 / GO语言中文网
昨天，我在 Quora 上回答了一个关于 Go 语言并发模型的问题。现在，我觉得我还想再多说些什么！并发性是 Go 语言中最强大的特性之一。许多人讨论了这个话题，从非常简单到过于复杂的都有。今天，我也来说说我的看法。 Go 语言的并发性是一种思维方式而不仅仅是一个语法。为了利用 Go 的强大功能，你需要首先了解 Go 是如何实现代码的并发执行。Go 依赖于一个叫做 CSP（Comminicating Sequential Process 通信顺序进程）的并发模型，在计算机科学中，它基本上是描述并发系统之间的交互模型。但是鉴于这不是一篇科学论文，我会跳过那些繁琐的过程......
142 天前 / 王下_邀月熊
写文章并发面试必备系列之进程、线程与协程王下邀月熊公众号：某熊的技术之路9 人赞同了该文章坐标上海松江高科技园，诚聘高级前端工程师/高级 Java 工程师，有兴趣的看 JD：https://www.lagou.com/jobs/63...并发面试必备系列之进程、线程与协程在 《Awesome Interviews》归纳的常见面试题中，无论前后端，并发与异步的相关知识都是面试的中重中之重，《并发编程》系列即对于面试中常见的并发知识再进行回顾总结；你也可以前往 《Awesome Interviews》，在实际的面试题考校中了解自己的掌握程度。也可以前往《Java 实战》、《Go 实战》等了解具体......
142 天前 / 王下_邀月熊
写文章并发面试必备系列之并发基础与内存模型王下邀月熊公众号：某熊的技术之路18 人赞同了该文章坐标上海松江高科技园，诚聘高级前端工程师/高级 Java 工程师，有兴趣的看 JD：https://www.lagou.com/jobs/63...并发面试必备系列之并发基础与内存模型在 《Awesome Interviews》归纳的常见面试题中，无论前后端，并发与异步的相关知识都是面试的中重中之重，本系列即对于面试中常见的并发知识再进行回顾总结；你也可以前往 《Awesome Interviews》，在实际的面试题考校中了解自己的掌握程度。也可以前往《Java 实战》、《Go 实战》等了解具体编程语......
142 天前 / 风来风往风伤(TiAmo)
《并发扣款，如何保证数据的一致性？》，分享了同一个用户并发扣款时，有一定概率出现数据不一致，可以使用CAS乐观锁的方式，在不降低吞吐量，并且只有少量修改的情况下，保证数据的一致性。 文章发布不到24小时，就有近200的评论。 其中，问的比较多的是ABA问题，这个问题已经在《并发扣款一致性优化，CAS下ABA问题，这个话题还没聊完！！！》中扩展。其次，问的比较多的是作业题，为什么一定要用select&set的方式进行余额写回：UPDATE t_yue SET money=$new_money WHERE uid=$uid AND money=$old_money; 为什么不能采用直接扣减的方法：UP......
151 天前 / GO语言中文网
写代码难，写处理并行和并发的代码更难！要做到这一切并保持高效将是极具挑战性的。 今天，我决定开始分享一些技巧来处理某些特殊情况。 定时 Channel 操作有时，你想要为你的 Channel 操作定时：持续尝试做一些事情，如果不能在一段时间内完成就放弃继续尝试。 要做到这一点，你可以使用 context 或者 time，两者都很好。context可能更惯用，而 time 则更高效，但它们几乎是完全相同的： 1funcToChanTimedContext(ctxcontext.Context,dtime.Duration,messageType,cchan<-Type)(writtenbool){ 2ctx,cancel:=context.WithTimeout(ctx,d) 3de......