rsocket-core 1.1.4 · io.rsocket.internal.jctools.queues.MpscUnboundedArrayQueue

Field Summary

Modifier and Type	Field and Description
pack-priv byte	b000 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b000.
pack-priv byte	b001 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b001.
pack-priv byte	b002 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b002.
pack-priv byte	b003 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b003.
pack-priv byte	b004 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b004.
pack-priv byte	b005 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b005.
pack-priv byte	b006 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b006.
pack-priv byte	b007 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b007.
pack-priv byte	b010 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b010.
pack-priv byte	b011 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b011.
pack-priv byte	b012 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b012.
pack-priv byte	b013 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b013.
pack-priv byte	b014 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b014.
pack-priv byte	b015 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b015.
pack-priv byte	b016 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b016.
pack-priv byte	b017 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b017.
pack-priv byte	b020 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b020.
pack-priv byte	b021 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b021.
pack-priv byte	b022 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b022.
pack-priv byte	b023 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b023.
pack-priv byte	b024 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b024.
pack-priv byte	b025 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b025.
pack-priv byte	b026 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b026.
pack-priv byte	b027 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b027.
pack-priv byte	b030 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b030.
pack-priv byte	b031 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b031.
pack-priv byte	b032 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b032.
pack-priv byte	b033 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b033.
pack-priv byte	b034 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b034.
pack-priv byte	b035 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b035.
pack-priv byte	b036 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b036.
pack-priv byte	b037 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b037.
pack-priv byte	b040 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b040.
pack-priv byte	b041 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b041.
pack-priv byte	b042 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b042.
pack-priv byte	b043 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b043.
pack-priv byte	b044 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b044.
pack-priv byte	b045 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b045.
pack-priv byte	b046 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b046.
pack-priv byte	b047 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b047.
pack-priv byte	b050 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b050.
pack-priv byte	b051 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b051.
pack-priv byte	b052 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b052.
pack-priv byte	b053 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b053.
pack-priv byte	b054 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b054.
pack-priv byte	b055 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b055.
pack-priv byte	b056 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b056.
pack-priv byte	b057 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b057.
pack-priv byte	b060 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b060.
pack-priv byte	b061 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b061.
pack-priv byte	b062 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b062.
pack-priv byte	b063 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b063.
pack-priv byte	b064 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b064.
pack-priv byte	b065 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b065.
pack-priv byte	b066 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b066.
pack-priv byte	b067 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b067.
pack-priv byte	b070 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b070.
pack-priv byte	b071 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b071.
pack-priv byte	b072 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b072.
pack-priv byte	b073 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b073.
pack-priv byte	b074 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b074.
pack-priv byte	b075 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b075.
pack-priv byte	b076 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b076.
pack-priv byte	b077 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b077.
pack-priv byte	b100 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b100.
pack-priv byte	b101 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b101.
pack-priv byte	b102 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b102.
pack-priv byte	b103 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b103.
pack-priv byte	b104 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b104.
pack-priv byte	b105 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b105.
pack-priv byte	b106 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b106.
pack-priv byte	b107 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b107.
pack-priv byte	b110 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b110.
pack-priv byte	b111 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b111.
pack-priv byte	b112 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b112.
pack-priv byte	b113 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b113.
pack-priv byte	b114 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b114.
pack-priv byte	b115 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b115.
pack-priv byte	b116 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b116.
pack-priv byte	b117 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b117.
pack-priv byte	b120 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b120.
pack-priv byte	b121 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b121.
pack-priv byte	b122 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b122.
pack-priv byte	b123 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b123.
pack-priv byte	b124 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b124.
pack-priv byte	b125 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b125.
pack-priv byte	b126 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b126.
pack-priv byte	b127 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b127.
pack-priv byte	b130 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b130.
pack-priv byte	b131 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b131.
pack-priv byte	b132 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b132.
pack-priv byte	b133 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b133.
pack-priv byte	b134 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b134.
pack-priv byte	b135 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b135.
pack-priv byte	b136 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b136.
pack-priv byte	b137 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b137.
pack-priv byte	b140 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b140.
pack-priv byte	b141 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b141.
pack-priv byte	b142 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b142.
pack-priv byte	b143 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b143.
pack-priv byte	b144 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b144.
pack-priv byte	b145 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b145.
pack-priv byte	b146 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b146.
pack-priv byte	b147 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b147.
pack-priv byte	b150 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b150.
pack-priv byte	b151 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b151.
pack-priv byte	b152 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b152.
pack-priv byte	b153 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b153.
pack-priv byte	b154 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b154.
pack-priv byte	b155 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b155.
pack-priv byte	b156 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b156.
pack-priv byte	b157 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b157.
pack-priv byte	b160 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b160.
pack-priv byte	b161 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b161.
pack-priv byte	b162 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b162.
pack-priv byte	b163 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b163.
pack-priv byte	b164 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b164.
pack-priv byte	b165 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b165.
pack-priv byte	b166 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b166.
pack-priv byte	b167 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b167.
pack-priv byte	b170 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b170.
pack-priv byte	b171 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b171.
pack-priv byte	b172 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b172.
pack-priv byte	b173 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b173.
pack-priv byte	b174 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b174.
pack-priv byte	b175 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b175.
pack-priv byte	b176 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b176.
pack-priv byte	b177 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b177.

Access	Constructor and Description
public	MpscUnboundedArrayQueue(int chunkSize)

Modifier and Type	Method and Description
protected long	availableInQueue(long pIndex, long cIndex) Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.availableInQueue.
public int	capacity() Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.capacity. Implements io.rsocket.internal.jctools.queues.MessagePassingQueue.capacity.
public int	drain(MessagePassingQueue.Consumer<E> c) Overrides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.drain. Implements io.rsocket.internal.jctools.queues.MessagePassingQueue.drain. Remove all available item from the queue and hand to consume.
public int	fill(MessagePassingQueue.Supplier<E> s) Overrides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.fill. Implements io.rsocket.internal.jctools.queues.MessagePassingQueue.fill. Stuff the queue with elements from the supplier.
protected long	getCurrentBufferCapacity(long mask) Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity.
protected int	getNextBufferSize(E[] buffer) Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.getNextBufferSize.

b000	back to summary
pack-priv byte b000 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b000.

b001	back to summary
pack-priv byte b001 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b001.

b002	back to summary
pack-priv byte b002 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b002.

b003	back to summary
pack-priv byte b003 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b003.

b004	back to summary
pack-priv byte b004 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b004.

b005	back to summary
pack-priv byte b005 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b005.

b006	back to summary
pack-priv byte b006 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b006.

b007	back to summary
pack-priv byte b007 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b007.

b010	back to summary
pack-priv byte b010 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b010.

b011	back to summary
pack-priv byte b011 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b011.

b012	back to summary
pack-priv byte b012 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b012.

b013	back to summary
pack-priv byte b013 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b013.

b014	back to summary
pack-priv byte b014 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b014.

b015	back to summary
pack-priv byte b015 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b015.

b016	back to summary
pack-priv byte b016 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b016.

b017	back to summary
pack-priv byte b017 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b017.

b020	back to summary
pack-priv byte b020 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b020.

b021	back to summary
pack-priv byte b021 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b021.

b022	back to summary
pack-priv byte b022 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b022.

b023	back to summary
pack-priv byte b023 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b023.

b024	back to summary
pack-priv byte b024 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b024.

b025	back to summary
pack-priv byte b025 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b025.

b026	back to summary
pack-priv byte b026 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b026.

b027	back to summary
pack-priv byte b027 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b027.

b030	back to summary
pack-priv byte b030 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b030.

b031	back to summary
pack-priv byte b031 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b031.

b032	back to summary
pack-priv byte b032 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b032.

b033	back to summary
pack-priv byte b033 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b033.

b034	back to summary
pack-priv byte b034 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b034.

b035	back to summary
pack-priv byte b035 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b035.

b036	back to summary
pack-priv byte b036 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b036.

b037	back to summary
pack-priv byte b037 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b037.

b040	back to summary
pack-priv byte b040 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b040.

b041	back to summary
pack-priv byte b041 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b041.

b042	back to summary
pack-priv byte b042 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b042.

b043	back to summary
pack-priv byte b043 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b043.

b044	back to summary
pack-priv byte b044 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b044.

b045	back to summary
pack-priv byte b045 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b045.

b046	back to summary
pack-priv byte b046 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b046.

b047	back to summary
pack-priv byte b047 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b047.

b050	back to summary
pack-priv byte b050 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b050.

b051	back to summary
pack-priv byte b051 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b051.

b052	back to summary
pack-priv byte b052 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b052.

b053	back to summary
pack-priv byte b053 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b053.

b054	back to summary
pack-priv byte b054 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b054.

b055	back to summary
pack-priv byte b055 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b055.

b056	back to summary
pack-priv byte b056 Hides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueuePad3.b056.

Method Detail

availableInQueue

back to summary

protected long availableInQueue(long pIndex, long cIndex)

Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.availableInQueue.

Returns:long

Doc from io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.availableInQueue.

available elements in queue * 2

Annotations

@Override

capacity back to summary

public int capacity()

Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.capacity.

Implements io.rsocket.internal.jctools.queues.MessagePassingQueue.capacity.

Returns:int

Doc from io.rsocket.internal.jctools.queues.MessagePassingQueue.capacity.

the capacity of this queue or MessagePassingQueue#UNBOUNDED_CAPACITY if not bounded

Annotations

@Override

drain back to summary

public int drain(MessagePassingQueue.Consumer<E> c)

Overrides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.drain.

Implements io.rsocket.internal.jctools.queues.MessagePassingQueue.drain.

Doc from io.rsocket.internal.jctools.queues.MessagePassingQueue.drain.

Remove all available item from the queue and hand to consume. This should be semantically similar to:

M m;
while((m = relaxedPoll()) != null){
c.accept(m);
}

There's no strong commitment to the queue being empty at the end of a drain. Called from a consumer thread subject to the restrictions appropriate to the implementation.

Warning

Explicit assumptions are made with regards to Consumer#accept make sure you have read and understood these before using this method.

Returns:int

the number of polled elements

Annotations

@Override

fill back to summary

public int fill(MessagePassingQueue.Supplier<E> s)

Overrides io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.fill.

Implements io.rsocket.internal.jctools.queues.MessagePassingQueue.fill.

Doc from io.rsocket.internal.jctools.queues.MessagePassingQueue.fill.

Stuff the queue with elements from the supplier. Semantically similar to:

while(relaxedOffer(s.get());

There's no strong commitment to the queue being full at the end of a fill. Called from a producer thread subject to the restrictions appropriate to the implementation.

Unbounded queues will fill up the queue with a fixed amount rather than fill up to oblivion.

Warning

Explicit assumptions are made with regards to Supplier#get make sure you have read and understood these before using this method.

Returns:int

the number of offered elements

Annotations

@Override

getCurrentBufferCapacity

back to summary

protected long getCurrentBufferCapacity(long mask)

Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity.

Returns:long

Doc from io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity.

current buffer capacity for elements (excluding next pointer and jump entry) * 2

Annotations

@Override

getNextBufferSize

back to summary

protected int getNextBufferSize(E[] buffer)

Implements abstract io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.getNextBufferSize.

Returns:int

Doc from io.rsocket.internal.jctools.queues.BaseMpscLinkedArrayQueue.getNextBufferSize.

next buffer size(inclusive of next array pointer)

Annotations

@Override

public Class MpscUnboundedArrayQueue<E>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail