无锁的思想 众所周知，Java中对并发控制的最常见方法就是锁，锁能保证同一时刻只能有一个线程访问临界区的资源，从而实现线程安全。然而，锁虽然有效，但采用的是一种悲观的策略。它假设每一次对临界区资源的访问都会发生冲突，当有一个线程访问资源，其他线程就必须等待，所以锁是会阻塞线程执行的。 当然，凡事都有两面，有悲观就会有乐观。而无锁就是一种乐观的策略，它假设线程对资源的访问是没有冲突的，同时所有的线程执行都...
一.线程不安全的HashMap 多线程环境下，使用HashMap进行put操作会引起死循环（jdk1.7 Entry链表形成环形数据结构），导致CPU利用率接近100%。 二.效率低下的HashTable 多个线程访问HashTable的同步方法，会引起阻塞或轮询状态。 三.ConcurrentHashMap jdk1.7 锁分段技术 数据分段存储，每段配一把锁，当一个线程访问其中一段时，其他线程也可访问其他段。 结构：Segment数组，每个数组下面维护HashEntry链表（存键值对）http://www...
1、概述 Condition 接口也提供了类似 Object 的监视器方法，它与 Lock 配合可以实现 等待/通知 模式， 当要实现一个等待/通知模式时，我们首先想到的就是 synchronized 同步关键字，它配合 Object 的 wait()、notify() 等系列方法实现。 还有一种实现方式，那就是使用显式锁 Lock ，配合 Condition 也可以实现等待/通知模式。 Object的监控器方法 和 Condition 接口，两者在使用方式及功能特性上还是有差别的，对比如下：对比项...
jdk1.5以后，并发包中新增了lock接口， 它相对于synchronized，多了以下三个主要特性：尝试非阻塞地获取锁（尝试获取锁成功则持有）、能被中断地获取锁（锁的进程能响应中断）、超时获取锁（指定时间截止之前获取锁）。 我们看看它接口中定义的api: 获取锁 可中断地获取锁 尝试非阻塞地获取锁，能够获取则返回true，否则false 超时获取锁，三种返回情况：1、当前线程在超时时间内获得了锁。2、当前线程在超时时间内被中断。3、超时...
在前面的文章中我们讲述了创建线程的2种方式，一种是直接继承Thread，另外一种就是实现Runnable接口。这2种方式都有一个缺陷就是：在执行完任务之后无法获取执行结果。如果需要获取执行结果，就必须通过共享变量或者使用线程通信的方式来达到效果，这样使用起来就比较麻烦。而自从Java 1.5开始，就提供了Callable和Future，通过它们可以在任务执行完毕之后得到任务执行结果。今天我们就来讨论一下Callable、Future和FutureTask三个...
最近在学习java并发编程基础.一切从简,以能理解概念为主. 并发编程肯定绕不过线程.这是最基础的. 那么就从在java中,如何使用线程开始. 继承Thread类 继承Thread类,重写run方法,new出对象,调用start方法. 在新启的线程里运行的就是重写的run方法. 1 /**2 * 集成Thread类 实现run()3 */4 public class C1 extends Thread {5 6 @Override7 public void run() {8 try {9 Thread.sleep(100); 10 ...
关于线程安全的例子，我前面的文章Java并发编程：线程安全和ThreadLocal里面提到了,简而言之就是多个线程在同时访问或修改公共资源的时候，由于不同线程抢占公共资源而导致的结果不确定性，就是在并发编程中经常要考虑的线程安全问题。前面的做法是使用同步语句synchronized来隐式加锁，现在我们尝试来用Lock显式加锁来解决线程安全的问题，先来看一下Lock接口的定义: public interface Lock 1 Lock接口有几个...
在Java中，可以通过配合调用Object对象的wait（）方法和notify（）方法或notifyAll（）方法来实现线程间的通信。在线程中调用wait（）方法，将阻塞等待其他线程的通知（其他线程调用notify（）方法或notifyAll（）方法），在线程中调用notify（）方法或notifyAll（）方法，将通知其他线程从wait（）方法处返回。Object是所有类的超类，它有5个方法组成了等待/通知机制的核心：notify（）、notifyAll（）、wait（）、wait（long）和...
JAVA大数据中高级架构 2018-11-10 14:04:32当线程需要同时持有多个锁时，有可能产生死锁。考虑如下情形： 线程A当前持有互斥所锁lock1，线程B当前持有互斥锁lock2。接下来，当线程A仍然持有lock1时，它试图获取lock2，因为线程B正持有lock2，因此线程A会阻塞等待线程B对lock2的释放。如果此时线程B在持有lock2的时候，也在试图获取lock1，因为线程A正持有lock1，因此线程B会阻塞等待A对lock1的释放。二者都在等待对方所持有锁的释放...
在并发编程中，多线程同时并发访问的资源叫做临界资源，当多个线程同时访问对象并要求操作相同资源时，分割了原子操作就有可能出现数据的不一致或数据不完整的情况，为避免这种情况的发生，我们会采取同步机制，以确保在某一时刻，方法内只允许有一个线程。 采用synchronized修饰符实现的同步机制叫做互斥锁机制，它所获得的锁叫做互斥锁。每个对象都有一个monitor(锁标记)，当线程拥有这个锁标记时才能访问这个资源，没有锁标记便...
Java中实现多线程有两种方法：继承Thread类、实现Runnable接口，在程序开发中只要是多线程，肯定永远以实现Runnable接口为主，因为实现Runnable接口相比继承Thread类有如下优势： 1、可以避免由于Java的单继承特性而带来的局限； 2、增强程序的健壮性，代码能够被多个线程共享，代码与数据是独立的； 3、适合多个相同程序代码的线程区处理同一资源的情况。 下面以典型的买票程序（基本都是以这个为例子）为例，来说明二者的区别。 ...
守护线程Java中有两类线程：User Thread(用户线程)、Daemon Thread(守护线程) 用户线程即运行在前台的线程，而守护线程是运行在后台的线程。 守护线程作用是为其他前台线程的运行提供便利服务，而且仅在普通、非守护线程仍然运行时才需要，比如垃圾回收线程就是一个守护线程。当VM检测仅剩一个守护线程，而用户线程都已经退出运行时，VM就会退出，因为没有如果没有了被守护这，也就没有继续运行程序的必要了。如果有非守护线程仍然...
JAVA大数据中高级架构 2018-11-06 14:24:56挂起和恢复线程Thread 的API中包含两个被淘汰的方法，它们用于临时挂起和重启某个线程，这些方法已经被淘汰，因为它们是不安全的，不稳定的。如果在不合适的时候挂起线程（比如，锁定共享资源时），此时便可能会发生死锁条件——其他线程在等待该线程释放锁，但该线程却被挂起了，便会发生死锁。另外，在长时间计算期间挂起线程也可能导致问题。 下面的代码演示了通过休眠来延缓运行，模拟...
使用interrupt（）中断线程当一个线程运行时，另一个线程可以调用对应的Thread对象的interrupt（）方法来中断它，该方法只是在目标线程中设置一个标志，表示它已经被中断，并立即返回。这里需要注意的是，如果只是单纯的调用interrupt（）方法，线程并没有实际被中断，会继续往下执行。 下面一段代码演示了休眠线程的中断: public class SleepInterrupt extends Object implements Runnable{public void run(){try{System.out.prin...
每个Java对象都可以用做一个实现同步的锁，这些锁被称为内置锁或监视器锁。线程在进入同步代码块之前会自动获取锁，并且在退出同步代码块时会自动释放锁。获得内置锁的唯一途径就是进入由这个锁保护的同步代码块或方法。 当某个线程请求一个由其他线程持有的锁时，发出请求的线程就会阻塞。然而，由于内置锁是可重入的，因此如果摸个线程试图获得一个已经由它自己持有的锁，那么这个请求就会成功。“重入”意味着获取锁的操作的粒度...