天天看点

和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值

1 锁的对象和范围

  • 缩小粒度
和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值
和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值

2 锁的对象本身大小

  • 减少空间占用
和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值

Atomic long V.S long

前者是个对象,包含对象头(object header)以保存hashcode、lock 等信息,64 位系统下占16字节,64位系统下:

  • volatile long= 8 bytesAtomicLong = 8 bytes (volatile long) + 16bytes (对象头) + 8 bytes (引用) = 32 bytes

    至少节约24字节!

所以 Atomic* objects =》 Volatile primary type + Static Atomic*FieldUpdater

3 锁的速度

提高并发性

LongCounter

记录内存分配字节数等功能用到的。

高并发下: java.util.concurrent.atomic.AtomicLong => java.util.concurrent.atomic.LongAdder

和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值

结论:及时衡量、使用JDK最新的功能

根据不同情况,选择不同的并发包实现

JDK< 1.8考虑ConcurrentHashMapV8 ( ConcurrentHashMap在jDK8中的版本)

和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值

4 不同场景选择不同的并发类

因需而变

  • 关闭和等待关闭事件执行器( Event Executor):

    Object.wait/ notify =》 CountDownLatch

和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值
  • Nio Event loop中负责存储task的Queue

Jdk’s LinkedBlockingQueue (MPMC,多生产者多消费者) -> jctools’ MPSC

io.netty.util.internal.PlatformDependent.Mpsc#newMpscQueue(int):

和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值
和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值

5 锁的价值

能不用则不用

Netty应用场景下:局部串行+整体并行>- -个队列+多个线程模式:

降低用户开发难度、逻辑简单、提升处理性能

避免锁带来的上下文切换和并发保护等额外开销

避免用锁:用ThreadLocal来避免资源争用,例如Netty轻量级的线程池实现

和Netty学习Java锁的使用1 锁的对象和范围2 锁的对象本身大小3 锁的速度4 不同场景选择不同的并发类5 锁的价值
上一篇: 锁的分类