Java中的ConcurrentBitSet使用小结_Java

一、核心澄清：java标准库无内置concurrentbitset

java标准库（java.util包）中并未提供concurrentbitset类。原生bitset是线程不安全的，多线程环境下直接操作可能导致数据竞争和不一致。若需实现线程安全的位操作，需借助以下方案：

二、推荐方案：eclipse collections的concurrentbitset

1. 第三方库介绍

eclipse collections（原gs collections）是一个高性能的java集合框架，提供了线程安全的concurrentbitset实现，位于org.eclipse.collections.impl.bitset包中。其特点包括：

线程安全：通过内部锁机制保证多线程访问的安全性。
高效内存：基于long数组存储位数据，空间效率与原生bitset一致。
丰富api：支持所有原生bitset的操作（如set、clear、flip等），并扩展了并发场景下的专用方法。

2. 使用示例

(1) 添加依赖

<dependency>
    <groupid>org.eclipse.collections</groupid>
    <artifactid>eclipse-collections</artifactid>
    <version>11.1.0</version>
</dependency>

(2) 基本操作

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);
    }
}

(3) 高级功能

// 原子操作：检查并设置位（cas）
boolean success = bits.compareandswap(index, expectedvalue, newvalue);

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

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

三、替代方案：原生bitset的线程安全封装

1. 同步包装法

通过synchronized关键字或lock接口对bitset的操作进行同步：

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();
}

2. 原子变量法

使用atomiclongarray实现更细粒度的并发控制（适用于简单位操作）：

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);

四、方案对比与选型建议

方案	优点	缺点	适用场景
eclipse collections concurrentbitset	线程安全、api丰富、性能优异	需引入第三方库	高并发位操作、复杂位运算
同步包装法	实现简单、兼容原生bitset	性能瓶颈、粗粒度锁	低并发场景、简单位操作
原子变量法	细粒度控制、无锁化	实现复杂、仅支持简单位操作	高性能要求、简单位标记