生产者和消费者模型是操作系统中经典的同步问题。该问题最早由Dijkstra提出，用以演示它提出的信号量机制。经典的生产者和消费者模型的描写叙述是：有一群生产者进程在生产产品。并将这些产品提供给消费者进程去消费。为使生产者进程与消费者进程能并发执行，在两者之间设置了一个具有n个缓冲区的缓冲池，生产者进程将它所生产的产品放入一个缓冲区中。消费者进程可从一个缓冲区中取走产品去消费。虽然全部的生产者进程和消费者进程...
对象的发布与逸出 “发布（Publish）“一个对象是指使对象能够在当前作用域之外的代码中使用。可以通过 公有静态变量，非私有方法，构造方法内隐含引用 三种方式。 如果对象构造完成之前就发布该对象，就会破坏线程安全性。当某个不应该发布的对象被发布时，这种情况就被称为逸出（Escape）。下面我们首先来看看一个对象是如何逸出的。 发布对象最简单的方法便是将对象的引用保存到一个共有的静态变量中，以便...
首先介绍几个概念： wait()方法 wait()方法使得当前线程必须要等待，等到另外一个线程调用notify()或者notifyAll()方法。 当前的线程必须拥有当前对象的monitor，也即lock，就是锁。 线程调用wait()方法，释放它对锁的拥有权，然后等待另外的线程来通知它（通知的方式是notify()或者notifyAll()方法），这样它才能重新获得锁的拥有权和恢复执行。 要确保调用wait()方法的时候拥有锁，即，wait()方法的调用必须放在...
CountDownLatch、CyclicBarrier、Callable、Future 都位于java.util.concurrent包下，其中CountDownLatch和CyclicBarrier属于该包中的tools分支，Callable和Future属于该包中的executer分支。一.CountDownLatch CountDownLatch类位于java.util.concurrent包下，利用它可以实现类似计数器的功能。比如有一个任务A，它要等待其他4个任务执行完毕之后才能执行，此时就可以利用CountDownLatch来实现这种功能了。CountDownLatch类只...
一、异常原因与异常源码分析 对集合（List、Set、Map）迭代时对其进行修改就会出现java.util.ConcurrentModificationException异常。这里以ArrayList为例，例如下面的代码：ArrayList<String> list = new ArrayList<>(); list.add("1"); list.add("2"); list.add("3"); //遍历1for (String s : list){if (s.equals( "3")) {list.remove(s); // error } } //遍历2 Iterator<String> it = list.iterator(); for (; it.hasNext()...
.title { text-align: center } .todo { font-family: monospace; color: red } .done { color: green } .tag { background-color: #eee; font-family: monospace; padding: 2px; font-size: 80%; font-weight: normal } .timestamp { color: #bebebe } .timestamp-kwd { color: #5f9ea0 } .right { margin-left: auto; margin-right: 0px; text-align: right } .left { margin-left: 0px; margin-right: auto; text-align: left }...
综述java.util.concurrent 包含许多线程安全、测试良好、高性能的并发构建块。不客气地说，创建 java.util.concurrent 的目的就是要实现 Collection 框架对数据结构所执行的并发操作。通过提供一组可靠的、高性能并发构建块，开发人员可以提高并发类的线程安全、可伸缩性、性能、可读性和可靠性。如果一些类名看起来相似，可能是因为 java.util.concurrent 中的许多概念源自 Doug Lea 的 util.concurrent 库（请参阅 参考资料）。J...
一、锁的内存语义所为的java内存模型的内存语义指的就是在JVM中的实现原则。 锁的内存语义：锁除了让临界区互斥执行外，还可以让释放锁的线程向获取同一个锁的线程发送消息。 我们把上面这句话再整理下： 当线程释放锁时，JMM会把该线程对应的本地内存中的共享变量刷新到主内存中。 当线程获取锁时，JMM会把该线程对应的本地内存置为无效。从而使得被监视器保护的临界区代码必须要从主内存中去读取共享变量。 锁...
/** * * @author weip 书中讲到计数器count是线程安全(毋庸置疑,AtomicLong是命令级的线程安全), * 而计数器的状态就是servlet的状态,这是为何？ * */ @ThreadSafe public class CountingFactorizer extends GenericServlet implements Servlet {private final AtomicLong count = new AtomicLong(0);public long getCount() {return count.get();}public void service(ServletRequest req, ServletResponse resp) {...
最近一直整并发这块东西，顺便写点Java并发的例子，给大家做个分享，也强化下自己记忆。每天起早贪黑的上班，父母每天也要上班，话说今天定了个饭店，一家人一起吃个饭，通知大家下班去饭店集合。假设：3个人在不同的地方上班，必须等到3个人到场才能吃饭，用程序如何实现呢？作为一名资深屌丝程序猿，开始写代码实现：package com.zhy.concurrency.latch;public class Test1 {/*** 模拟爸爸去饭店*/public static void fatherToRe...
DelayQueue主要用于放置实现了Delay接口的对象，其中的对象只能在其时刻到期时才能从队列中取走。这种队列是有序的，即对头的延迟到期时间最短。如果没有任何延迟到期，那么久不会有任何头元素，并且poll()将返回null（正因为这样，你不能将null放置到这种队列中） 下面是一个示例，其中的Delayed对象自身就是人物，而DelayedTaskConsumer将最“紧急”的任务从队列中取出来，然后运行它：import java.util.ArrayList; import ja...
Java多线程开发中最重要的一点就是线程安全的实现了。所谓Java线程安全，可以简单理解为当多个线程访问同一个共享资源时产生的数据不一致问题。为此，Java提供了一系列方法来解决线程安全问题。synchronizedsynchronized用于同步多线程对共享资源的访问，在实现中分为同步代码块和同步方法两种。同步代码块 1publicclass DrawThread extends Thread {2 3private Account account;4privatedouble drawAmount;5public DrawThread(Str...
1.synchronized实现同步的基础 Java中的每个对象都是可以作为锁，具体有3种表现。 1.对于普通同步方法，锁是当前实例对象。 2.对于静态同步方法，锁是当前类的Class对象。 3.对于同步方法块，锁是Synchonized括号里面的配置对象。 当前一个线程试图访问同步代码块时，它首先必须得到锁，退出或者抛出异常时候必须释放锁。那么锁到底存在什么地方? 从JVM规范可以看到Synchonized在JVM里的实现原理，JVM基于进入和退出...
Java中线程中状态可分为五种：New（新建状态），Runnable（就绪状态），Running（运行状态），Blocked（阻塞状态），Dead（死亡状态）。 New：新建状态，当线程创建完成时为新建状态，即new Thread(...)，还没有调用start方法时，线程处于新建状态。 Runnable：就绪状态，当调用线程的的start方法后，线程进入就绪状态，等待CPU资源。处于就绪状态的线程由Java运行时系统的线程调度程序(thread scheduler)来调度。 Runnin...
转：https://www.cnblogs.com/MOBIN/p/5436482.html摘要： Eexecutor作为灵活且强大的异步执行框架，其支持多种不同类型的任务执行策略，提供了一种标准的方法将任务的提交过程和执行过程解耦开发，基于生产者-消费者模式，其提交任务的线程相当于生产者，执行任务的线程相当于消费者，并用Runnable来表示任务，Executor的实现还提供了对生命周期的支持，以及统计信息收集，应用程序管理机制和性能监视等机制。 1.Exexctor简...