问题 如何支持一个无容量限制的channel 取出元素会阻塞到元素存在并且返回 放入元素永远不会阻塞，都会立即返回 方法一：用两个chan加一个list模拟 在单独的goroutine处理入队和出队，这样不用给list加锁。 完整代码：https://github.com/luweimy/gouti ...
分类：
其他好文 时间：
2018-02-14 18:43:07
阅读次数：
975
什么是AbstractQueuedSynchronizer？为什么我们要分析它？ AQS:抽象队列同步器，原理是：当多个线程去获取锁的时候，如果获取锁失败了，当前线程就会被打包成一个node节点放入同步队列里面使用LockSuport的park方法阻塞起来，如果有线程释放了锁，放入同步队列的线程就会 ...
分类：
编程语言 时间：
2018-01-21 13:51:46
阅读次数：
191
C++多线程编程中通常会对共享的数据进行写保护，以防止多线程在对共享数据成员进行读写时造成资源争抢导致程序出现未定义的行为。通常的做法是在修改共享数据成员的时候进行加锁--mutex。在使用锁的时候通常是在对共享数据进行修改之前进行lock操作，在写完之后再进行unlock操作，进场会出现由于疏忽导 ...
分类：
其他好文 时间：
2017-12-17 13:16:14
阅读次数：
171
AQS源码详解 源码分析维度：同步队列、独占式同步状态获取与释放、共享式同步状态获取与释放以及超时获取同步状态等同步器的核心数据结构与模板方法。 同步队列介绍 同步器依赖内部的同步队列（一个FIFO双向队列）来完成同步状态的管理，当前线程获取同步状态失败时，同步器会将当前线程以及等待状态等信息构建成 ...
分类：
编程语言 时间：
2017-11-22 22:06:10
阅读次数：
288
Worker 是ThreadpoolExecutor的内部类 private final class Worker extends AbstractQueuedSynchronizer implements Runnable 继承了aqs，实现了runnable接口， aqs是一个同步队列，是ree ...
分类：
其他好文 时间：
2017-09-08 14:48:02
阅读次数：
386
Python 多线程同步队列模型 我面临的问题是有个非常慢的处理逻辑（比如分词、句法），有大量的语料，想用多线程来处理。 这一个过程可以抽象成一个叫“同步队列”的模型。 具体来讲，有一个生产者（Dispatcher）一方面从语料中读入句子，并且存入队列中，一方面看有没有空闲的消费者（Segmento ...
分类：
编程语言 时间：
2017-07-22 14:33:38
阅读次数：
201
在【Java并发编程实战】—–“J.U.C”：CLH队列锁提过，AQS里面的CLH队列是CLH同步锁的一种变形。其主要从双方面进行了改造：节点的结构与节点等待机制。在结构上引入了头结点和尾节点，他们分别指向队列的头和尾，尝试获取锁、入队列、释放锁等实现都与头尾节点相关。而且每一个节点都引入前驱节点和 ...
分类：
编程语言 时间：
2017-06-05 22:08:17
阅读次数：
328
Python3中的queue模块实现多生产者,多消费者队列,特别适用于多个线程间的信息的安全交换,主要有三个类 queue.Queue(maxsize=0) 构造一个FIFO(先进先出)的队列 queue.LifoQueue(maxsize=0) 构造一个LIFO(后进先出)的队列 queue.Pr ...
分类：
编程语言 时间：
2017-04-18 23:48:01
阅读次数：
441
此篇博客所有源码均来自JDK 1.8
在线程获取同步状态时如果获取失败，则加入CLH同步队列，通过通过自旋的方式不断获取同步状态，但是在自旋的过程中则需要判断当前线程是否需要阻塞，其主要方法在acqu...
分类：
编程语言 时间：
2017-03-24 12:24:30
阅读次数：
227
41 多用派发队列，少用同步锁 总结：当多个线程执行同一份代码时，可能会出现问题，这时有@synchronized(self){}内置同步块。或NSLock对象。然而这只是某种程度上的线程安全，使用串行同步队列(serial sychronization queue).更有效率的方法是使用串行队列同 ...
分类：
其他好文 时间：
2017-03-23 20:54:54
阅读次数：
309
