etl/docs/containers/queues & stacks/queue-spsc-atomic.md
John Wellbelove 4a88884b39
Issue/add hugo support for documentation (#1449)
* Add ranges

* Initial Hugo setup

* Work in progress

* Added selection for local or remote site

* Updated to 'light' theme

* Changed to using Hextra Hugo theme

* Changed to using Hextra Hugo theme

* Changed to Hextra Hugo theme

* Change to Hextra Hugo theme

* Updated Hugo setup.

* Updated Hugo setup.

# Conflicts:
#	docs/releases/_index.md

* Work in progress

* Added new fonts

Added new documentation

* Latest documentation updates

* Latest documentation updates

# Conflicts:
#	docs/containers/array.md
#	docs/containers/array_view.md
#	docs/containers/array_wrapper.md
#	docs/containers/bip_buffer_spsc_atomic.md
#	docs/containers/bitset.md
#	docs/containers/indirect_vector.md
#	docs/containers/vector.md
#	docs/getting-started/compilers.md

* Added bloom_filter markdown doc

* Added more documentation

Updated CSS for light and dark modes

* Fixed some menus

Added mode documentation files

* Updated CSS rules

Added badges to home page
Added uniqur_ptr + pool tutorial

* Fixed formatting on the home page markdown

Modified light amd dark code formatting

* Updated unique_ptr-with-pool

* Added container and shared message tutorials

* Updates to documentation

* Added const_multimap

* Updated source-formatting.md

* Added initial raw text files form Web site editor

* Innore coverage build directory

* Exported raw text documentation files from the web site editor

* Hugo updates

* Added Hugo intalation and markdown descriptions

* More addition to the documentation

* Added closure.md and updates to delegate.md

* Added format.md

* Added documentation for etl::delegate_observable, etl::function, Base64 codec

* Added io_port documentation

* Added basic_format_spec

* Added documentation for string_stream and string utilities.

* Added more documentation

Updated the documentation CSS

* Added documentation for clocks, day, duration

* Added more documentation for chrono classes

Updated callouts

* More chrono documentation

* Completed chrono documentation

* Maths functions documentation

* Completed maths documentation

* Completed maths documentation

* Completed maths documentation

* Completed maths documentation

* Added multiple documentation files

* Added iterator.md

* Added debug_count.md and versions.md

* Added debug_count.md and versions.md

* Added more documentation

* More documentation

* Added some design pattern documentation

Modified some of the layout files
Modified the About documentation

* Converted more documentation pages

Modified the site CSS

* Added more documentation

Moced some documentation files to new directories

* Added more documentation

Tweaks to CSS

* Added callback_timer_deferred_locked documentation

* Added callback_timer_locked documentation

* More documentation updates

* More documentation updates

* More documentation updates

* New documentation files.

Harmonised file name format

* New documentation files.

* Multiple document updates

* Multiple document updates

* Final conversion of web pages

* Updates before PR

* Updates before PR

* Updates before PR

# Conflicts:
#	docs/blog/_index.md

* Final pre PR updates

* Updates to message framework documentation

* Renamed directory

* Fix spelling

* Added author and date to blog files

Moved documentation files merged from development

* Fixed 'Description' typo

* Fix typos

# Conflicts:
#	docs/IO/io_port.md
#	docs/containers/sets/const-multiset.md
#	docs/containers/sets/const-set.md
#	docs/maths/correlation.md
#	docs/maths/gamma.md

* Renamed two files to lower case

* Minor renaming

* Added author and date

* Updated callout on bresenham_line.md

Added support for showing the ETL version on the documentation first page, by copying the version.txt file as a hugo asset.
Updated the Python 'update_release.py' to copy 'version.txt'

* Replace space in filename with hyphen.

Added more information to hugo-commands.md

* Replace space in filename with hyphen.

Added more information to hugo-commands.md

# Conflicts:
#	docs/getting-started/view-the-docs-locally/hugo-commands.md

* Added a link to pseudo_moving_average.md

* Updated title pages for groups

* Fixed missing 404 for non-existent pages

* Fixed coordinate variable names in the 'Calculating the intersection' example

---------

Co-authored-by: Roland Reichwein <Roland.Reichwein@bmw.de>
Co-authored-by: John Wellbelove <john.wellbelove@etlcpp.com>
Co-authored-by: John Wellbelove <john.wellbelove@etlcpp.co.uk>
2026-06-06 13:12:44 +01:00

187 lines
3.7 KiB
Markdown

---
title: "queue_spsc_atomic"
---
A fixed capacity single-producer, single-consumer queue for multi-threaded and interrupt driven systems.
The queue may be used to transfer data to or from two threads or an ISR.
The queue makes use of `etl::atomic_size_t`.
```cpp
etl::queue_spsc_atomic<typename T,
const size_t SIZE,
const size_t MEMORY_MODEL = etl::memory_model::MEMORY_MODEL_LARGE>
```
Inherits from `etl::iqueue_spsc_atomic<T>`.
`etl::iqueue_spsc_atomic` may be used as a size independent pointer or reference type for any `etl::queue_spsc_atomic` instance of the same implementation.
The memory model determines the type used internally for indexes and size, to allow for the most efficient implementation for the application.
## Maximum queue sizes
```cpp
MEMORY_MODEL_SMALL 255
MEMORY_MODEL_MEDIUM 65535
MEMORY_MODEL_LARGE 2147483647
MEMORY_MODEL_HUGE 9223372036854775807
```
See `memory_model.h`
## Member types
```cpp
value_type T
size_type <based on memory model>
pointer value_type*
const_pointer const value_type*
reference value_type&
const_reference const value_type&
```
## Constructor
```cpp
queue_spsc_atomic()
```
## Capacity
```cpp
bool empty() const
```
**Description**
Returns true if the size of the queue is zero, otherwise false.
Accurate from the 'pop' thread.
'Not empty' is a guess from the 'push' thread.
---
```cpp
bool full() const
```
**Description**
Returns true if the size of the queue is SIZE, otherwise false.
Accurate from the 'push' thread.
'Not full' is a guess from the 'pop' thread.
---
```cpp
size_t size() const
```
**Description**
Returns the size of the queue.
Due to concurrency, this is a guess.
---
```cpp
size_t available() const
```
**Description**
Returns the remaining available capacity in the queue.
Due to concurrency, this is a guess.
---
```cpp
ETL_CONSTEXPR size_t max_size() const
```
**Description**
Returns the maximum possible size of the queue.
---
```cpp
ETL_CONSTEXPR size_t capacity() const
```
**Description**
Returns the maximum possible size of the queue.
## Modifiers
```cpp
bool push(const T& value)
bool push(T&& value)
```
**Description**
Pushes a value to the back of the queue.
Returns true if successful, otherwise false.
---
```cpp
bool pop()
```cpp
**Description**
Pop a value from the front of the list.
Returns true if successful, otherwise false.
---
```cpp
bool pop(T& value)
bool pop(T&& value)
```
**Description**
Pop a value from the front of the list and place it in value.
Returns true if successful, otherwise false.
---
```cpp
void clear()
```
**Description**
Clears the queue to a size of zero.
Must be called from thread that pops the queue or when there is no possibility of concurrent access.
---
### C++03
```cpp
bool emplace(const T1& value1)
bool emplace(const T1& value1, const T2& value2)
bool emplace(const T1& value1, const T2& value2, const T3& value3)
bool emplace(const T1& value1, const T2& value2, const T3& value3, const T4& value4)
```
**Description**
Constructs an item in the the queue 'in place'.
### C++11
```cpp
bool emplace(Args&&… args)
```
**Description**
Constructs an item in the the queue 'in place'.
## Notes
Remember that thread context switches may occur between calls to the access protected functions. For example, a call to `empty()` may return `true`, but a subsequent call to `pop()` may succeed if a context switch occurred between the two and pushed a new value.
## Example
```cpp
etl::queue_spsc_atomic<char, 10> queue;
int main()
{
while (true)
{
char c;
if (queue.pop(c))
{
Print(c);
}
}
}
void Thread()
{
while (true)
{
queue.push('A');
}
}
```