mirror of
https://github.com/ETLCPP/etl.git
synced 2026-11-09 22:59:47 +08:00
* 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>
187 lines
3.7 KiB
Markdown
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');
|
|
}
|
|
}
|
|
```
|