001 java 线程基础

java 线程

java 传统线程同步

获取同步锁

synchronized :

等待 唤醒

synchronized(obj) {
obj.wait()  : 线程等待
obj.notify  :
obj.notifyAll ：
}

线程范围内的变量共享

ThreadLocal

class A {
private static ThreadLocal<A> tl=new ThreadLocal<A>()
//线程共享配置
public A getInstance() {
if(tl.get()==null) {
A a=new A();
tl.put(a)
}
}
}

线程之间共享变量

1：  将共享变量封装在一个类中，线程之间使用同一个对象
2：  将共享变量放在外部， runnable作为内部类使用，线程之间共享外部类变量
3：  1 2 点相结合

线程并发库 jdk5 之后

线程池

java.util.concurrent.atomic

提供原子操作

AtomicInteger 操作整数
AtomicIntegerArray 操作整数数组
AtomicIntegerFieldUdater  对类中的基本变量提供原子操作

线程池

Executors 类 -> ExecutorService

1：FixedThreadPool 固定线程池
2：CachedThreadPool 自动增加线程
3：SingleThreadPool  单线程池
4：ScheduledThreadPool

Callable,Future

Callable: 执行call方法，返回结果
Future:  获取Callable返回的结果
CompletionService： 特殊的线程池, 运行一组线程，take 返回最早结束的结果

Lock相关

并发库中的锁, 主要用于控制互斥， 相对于synchronized 更面向对象.

Lock / ReentrantLock: lock() 上锁, unlock() 解锁， 相对于synchronized

ReadWriteLock / ReentrantReadWriteLock: 一个资源能够被多个读线程访问，或者被一个写线程访问，但是不能同时存在读写线程.

读写锁， 读写互斥, 写写互斥, 读读并发: 但一个线程可以在获取写锁后再写入数据结束时再次获取读锁，之后释放写锁, 可以实现写/读的转换(锁降级).

Condition: condition.await() == obj.wait(), condition.signal() == obj.notify ， 和Lock 一块使用相当于 synchronize(obj) obj.wait(), obj.notify

sychronizer

Semaphere

控制访问资源的线程数， 例子: 厕所5个坑，来了6个人，就有一个人排队. 实现资源的互斥

Semaphere semaphere=new Semaphere(8); //声明总信号灯
semaphere.acquire();  // 获取可用的信号灯
semaphere.release()   //释放信号灯

CyclicBarrier

声明Barrier点, 只有所有的线程都在Barrier前等待的时候才会继续向下执行.

CyclicBarrier cb=new CyclicBarrier(3); // 声明3个barrier
cb.await();  // await() 3 次， 继续进行

CountDownLatch

倒计数的计数器. 当倒计数到0 时， 线程继续执行。

CountDownLatch cdl=new CountDownLatch(3);  // 3个基数
cdl.await()
cdl.countDown();  // 计数减1

Exchanger

实现两个线程之间的数据交换

Exchanger exchanger = new Exchanger()
exchanger.exchange

阻塞队列

ArrayBlockingQueue: 三种不同类型的Insert/Remove 方法。

LinkedBlockingQueue:

并发集合

同步集合

Collections.synchronizedMap()

CurrentSkipListMap : 提供排序功能
CopyOnWriteArrayList: