diff options
| author | nodist <kevin.comas.git@gmail.com> | 2026-06-15 11:49:47 -0400 |
|---|---|---|
| committer | nodist <kevin.comas.git@gmail.com> | 2026-06-15 11:49:47 -0400 |
| commit | 7842aabba533dbd639039dd341dd64ee47cd4cd7 (patch) | |
| tree | 2b9429acba5f036c88e7f2a470a3cdfff93bd2c2 /docs/application/shared.md | |
| parent | 7fd642630ee17f7150c1b881631acbe422b3a26b (diff) | |
atomic threading
Diffstat (limited to 'docs/application/shared.md')
| -rw-r--r-- | docs/application/shared.md | 30 |
1 files changed, 2 insertions, 28 deletions
diff --git a/docs/application/shared.md b/docs/application/shared.md index c5d7e9e..b666684 100644 --- a/docs/application/shared.md +++ b/docs/application/shared.md @@ -9,33 +9,7 @@ typedef struct _kpl_shared { KPL_POOL_HEADER(_kpl_shared); _Atomic bool mutating; bool mark; - kpl_class class; - kpl_task *queue_head, queue_tail; - pthread_mutex_t queue_mutex; + void *data; + kpl_atomic_queue queue; } kpl_shared; - -static _Atomic int32_t shared_threads_marked; - -static kpl_shared *shared_pool_sweep, *shared_pool; - -static pthread_mutex_t shared_pool_mutex; ``` - -## Tracing - -1. Once triggered add a init task to the async queue -2. This task moves the `shared_pool` to the `shared_pool_sweep` and sets the `shared_wait` to off for each thread -3. Each thread will run down its queue queue marking found shared objects -3. Once all have run and `shared_threads_marked == available_threads` add a mark and sweep task to the async queue -4. The async queue is moved to a temp queue and as each item on the tmep queue is marked it is moved back to the async queue -5. A sweep on the `shared_pool_sweep` is done -6. What remains on the `shared_pool_sweep` is added to `shared_pool` - -## Mutating - -1. Check if state of `mutating` - 1. If false, set to true and add the task to the `async_queue_pool` - 2. Once complete lock `queue_mutex` and check the `queue_pool` - 3. If empty set the state of `mutating` to false - 4. Else queue the next task -2. If the state of `mutating` is true add, lock `queue_mutex` the task to `queue_tail` |
