死磕Java——StampedLock

2019-05-10  本文已影响0人  Waldeinsamkeit4

一、死磕Java——StampedLock

StampedLockJDK1.8新增的一种基于容量的锁,可以说是对ReentrantReadWriteLock锁的一种补充,StampedLock提供了三种模式的读写控制,简单说明如下:

1.1.StampedLock基本的使用

1.1.1.writeLock写锁

class MyNumData {

    int num, age = 0;
    StampedLock stampedLock = new StampedLock();

    public void add(int x, int y) {
        long stamp = stampedLock.writeLock();
        try {
            num += x;
            age += y;
        } finally {
            stampedLock.unlockWrite(stamp);
        }
    }
}

1.2.StampedLock源码简单分析

1.2.1.Static变量含义

/** Number of processors, for spin control */
private static final int NCPU = Runtime.getRuntime().availableProcessors();

/** Maximum number of retries before enqueuing on acquisition */
private static final int SPINS = (NCPU > 1) ? 1 << 6 : 0;

/** Maximum number of retries before blocking at head on acquisition */
private static final int HEAD_SPINS = (NCPU > 1) ? 1 << 10 : 0;

/** Maximum number of retries before re-blocking */
private static final int MAX_HEAD_SPINS = (NCPU > 1) ? 1 << 16 : 0;

/** The period for yielding when waiting for overflow spinlock */
private static final int OVERFLOW_YIELD_RATE = 7; // must be power 2 - 1

/** The number of bits to use for reader count before overflowing */
private static final int LG_READERS = 7;

// Values for lock state and stamp operations
private static final long RUNIT = 1L;
private static final long WBIT  = 1L << LG_READERS;
private static final long RBITS = WBIT - 1L;
private static final long RFULL = RBITS - 1L;
private static final long ABITS = RBITS | WBIT;
private static final long SBITS = ~RBITS; // note overlap with ABITS

// Initial value for lock state; avoid failure value zero
private static final long ORIGIN = WBIT << 1;

// Special value from cancelled acquire methods so caller can throw IE
private static final long INTERRUPTED = 1L;

// Values for node status; order matters
private static final int WAITING   = -1;
private static final int CANCELLED =  1;

// Modes for nodes (int not boolean to allow arithmetic)
private static final int RMODE = 0;
private static final int WMODE = 1;
上一篇下一篇

猜你喜欢

热点阅读