天天看點

和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 鎖的價值
上一篇: 鎖的分類