Java描述信息

// ctl 是一个整形原子类 , 它即表示了状态 , 有记录了梳理
private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));
 //   : 此变量 记录了 “线程池中的任务数量”和“线程池的状态”两个信息
//    : 高3位表示"线程池状态"，低29位表示"线程池中的任务数量"
 //       - RUNNING : 111 : 该线程池能接收新任务 ,且能对新任务进行处理
 //       - SHUTDOWN : 000 : 不能接收新任务 ,但是可以对任务进行处理
//        - STOP : 001 : 不添加新任务 , 不对任务进行处理 , 会中断正在执行的任务
 //       - TIDYING : 010 : 当所有的任务已终止，ctl记录的"任务数量"为0，线程池会变为TIDYING状态
 //           - 当所有的任务已终止，ctl记录的"任务数量"为0，线程池会变为TIDYING状态
//        - TERMINATED : 011 : 线程池彻底终止的状态
        
        
// 对数量的统计很简单 , 因为是 低 29 位用来描述梳理 , 所以做正常的加减即可实现
private boolean compareAndIncrementWorkerCount(int expect) {
    return ctl.compareAndSet(expect, expect + 1);
}

private boolean compareAndDecrementWorkerCount(int expect) {
    return ctl.compareAndSet(expect, expect - 1);
}


// 对状态的修改则是通过位运算来做的
> S1 : 预先准备多种状态
private static final int RUNNING    = -1 << COUNT_BITS;
private static final int SHUTDOWN   =  0 << COUNT_BITS;
private static final int STOP       =  1 << COUNT_BITS;
private static final int TIDYING    =  2 << COUNT_BITS;
private static final int TERMINATED =  3 << COUNT_BITS;

> S2 : 判断是否是运行状态或停止状态
private static final int COUNT_BITS = Integer.SIZE - 3;
private static final int CAPACITY   = (1 << COUNT_BITS) - 1;
// ~CAPACITY将反转CAPACITY的值，也就是CAPACITY的高3位全部为1，低29位全部为0
// & 操作则可以得到高三位的值
private static int runStateOf(int c) { return c & ~CAPACITY; }
final boolean isRunningOrShutdown(boolean shutdownOK) {
    int rs = runStateOf(ctl.get());
    return rs == RUNNING || (rs == SHUTDOWN && shutdownOK);
}

3 << 60 | timestamp - 1504000000000L << 20 | workerId << 10 | random.nextInt(128);

// S1 : 初始化
private static final int NULL_HANDLE = -1;
private int passHandle = NULL_HANDLE;

// S2 : 写入 passHandler (PS : 此处是在 ObjectOutputStream 中)
 bout.writeInt(baseWireHandle + passHandle);


// S3 : 解析 passHandler
passHandle = bin.readInt() - baseWireHandle;
if (passHandle < 0 || passHandle >= handles.size()) {
    throw new StreamCorruptedException...
}


// S4 : 通过 Handler 取位数
Object lookupObject(int handle) {
    return (handle != NULL_HANDLE &&
            status[handle] != STATUS_EXCEPTION) ?
        entries[handle] : null;
}

private static final byte STATUS_OK = 1;
private static final byte STATUS_UNKNOWN = 2;
private static final byte STATUS_EXCEPTION = 3;