Java中的ConcurrentBitSet使用小结

<dependency>
    <groupId>org.eclipse.collections</groupId>
    <artifactId>eclipse-collections</artifactId>
    <version>11.1.0</version>
</dependency>

import org.eclipse.collections.impl.bitset.ConcurrentBitSet;

public class ConcurrentBitSetDemo {
    public static void main(String[] args) {
        // 创建并发BitSet实例
        ConcurrentBitSet bits = new ConcurrentBitSet(100);

        // 多线程操作示例
        ExecutorService executor = Executors.newFixedThreadPool(4);
        for (int i = 0; i < 4; i++) {
            executor.execute(() -> {
                for (int j = 0; j < 1000; j++) {
                    // 线程安全地设置位
                    bits.set(j % 100);
                    // 线程安全地清除位
                    if (j % 50 == 0) {
                        bits.clear(j % 100);
                    }
                }
            });
        }
        executor.shutdown();
        while (!executor.isTerminated()) {
            // 等待所有任务完成
        }
        System.out.println("Final state: " + bits);
    }
}

// 原子操作：检查并设置位（CAS）
boolean success = bits.compareAndSwap(index, expectedValue, newValue);

// 并发统计：计算true位的数量
int count = bits.cardinality();

// 并发位运算：与另一个BitSet执行AND操作
ConcurrentBitSet other = new ConcurrentBitSet(100);
bits.and(other);

BitSet bits = new BitSet();
Lock lock = new ReentrantLock();

// 写操作
lock.lock();
try {
    bits.set(10);
} finally {
    lock.unlock();
}

// 读操作
lock.lock();
try {
    boolean value = bits.get(10);
} finally {
    lock.unlock();
}

AtomicLongArray array = new AtomicLongArray(100);

// 设置第50位
int index = 50 / 64;
int bit = 50 % 64;
long mask = 1L << bit;

boolean success = array.compareAndSwap(index, array.get(index), array.get(index) | mask);