list实现类说明
// hashMap特点是数组+链表,当链表长度=8的时候,链表会拓展成红黑树
// 数组长度为2的倍数,默认长度是16,加载因子是0.75
Map<String, String> map2 = new HashMap<>();
// concurrentmap特点是数组+链表,当链表长度=8的时候,会拓展成红黑树;并发的时候并非全局上锁,
//而是锁链表的头结点,使用synchronized
// 数组长度为2的倍数
Map<String, String> map = new ConcurrentHashMap<>(10);
// 存储方式是数组、通过modcount判断是否被修改、
//扩容方式是system.arraycory,每次扩容是上一次的1.5倍
List<String> list = new ArrayList<String>();
// 链表结构,查询时候会判断index在上半截还是下半截,如果是下半截,那就从尾部开始往前查找
// 虽然继承deque,但是不是双向链表结构
// 也是通过modcount来判断是否被修改过
List<String> linklist = new LinkedList<>();
// 并发链表,链表结构,通过for+cas的方式更新节点。size的长度是通过遍历链表得来的。
// 新增节点的时候,先修改tail节点的next,然后判断tail != next的时候才更新tail,(延迟更新,提升效率)
// 所以1.tail并不是真正意义上面的最后节点 2.分开更新提供了效率,
//因为并发情况下更新tail的次数更小了。这里使用的是weakCompareAndSet(可能原子性更新)
ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<String>();
queue实现类说明
// 数组结构的有界阻塞队列,线程安全类
// 使用reentrantlock实现全局方法加锁,只有一把锁
// 和两个condition实现put和task的阻塞,可以使用公平和非公平锁,默认是非公平
BlockingQueue blockQueue = new ArrayBlockingQueue<String>(10);
// 链表结构的有界阻塞队列
// 使用两把reentrantlock锁,一把put锁,一把task锁。
// 所有写入方法都要先获取put锁,所有删除数据都要先获取task锁。
// 队列的元素个数使用atmoicinteger记录,
//写入的时候判断元素个数是否等于队列容量,是的则使用put锁的condition.await阻塞方法,
// 写入成功之后判断当前队列元素个数+1小于容量就唤醒一个锁
// 所有获取元素都要先获取task锁,然后判断当前队列容量等于0则是使用task锁的condition.await阻塞线程
// 成功获取元素之后,判断当前队列元素个数是否大于1,大于则唤醒一个线程
// 使用atomicinteger原子性更新队列元素个数
// remove,contains,toArray,clear,获取iterator(next方法)等都要先获取put和task锁
blockQueue = new LinkedBlockingQueue<String>(10);
// 一个支持优先级排序的无界队列
// 数组方式存储,默认长度是8,最大尝试是integer.max_value - 8
// 一把reentrantlock锁,针对所有publie方法
// 回头来看priorityqueue队列吧
// PriorityBlockingQueue是一个无界队列,扩容方式是容量小于64的时候,
// 扩容每次+2,超过64的时候,每次扩容1.5倍
// 当容量满的时候,put没有阻塞,而是扩容
// 当容量等于=0的时候,task会阻塞。
blockQueue = new PriorityBlockingQueue<String>();
// 一个使用优先级队列实现的延迟无界队列
// 使用reentrantlock一把锁
// 写入的对象需要实现Delayed接口类,也是使用priorityqueue队列
// 写入的时候,包括put都使用offer方法,不阻塞写入
// 读取的时候task会阻塞,结合priorityqueue和获取第一个元素,
// 判断时间是否大于等于设置的运行时间,如果是则返回,否则阻塞线程
blockQueue = new DelayQueue<MyDelay>();
// 一个不存储元素的阻塞队列
// 内部使用公平和非公平传输方式,公平就是先进先出,非公平就是后进先出
// 使用for循环+cas的方式,写入数据。查询数据一样,其实他们都是使用同一个底层方法,for+cas对head的写入。写入是写入具体snode值,读取是写入null值
blockQueue = new SynchronousQueue<String>();
// 一个由链表结构组成的无界队列
// for+cas方式写入
// 多了tryTransfer和transfer方法,如果当前有消费者正在等待接受元素,transfer则把生产者传入的元素立即给消费者。
// 如果没有消费在等待元素,transfer会把元素放入tail节点,并等待该元素被消费才返回。
// tryTransfer是无论消费者是否接受,立刻返回
// 这里面的说明好像不对
blockQueue = new LinkedTransferQueue<String>();
// 一个由链表组成的双向阻塞队列
// 一把reentrantlock锁,两个condition,最大长度为integer.max_value
blockQueue = new LinkedBlockingDeque<String>();