summaryrefslogtreecommitdiffstats
path: root/library/cpp/threading
Commit message (Collapse)AuthorAgeFilesLines
* 'inline' is redundant hereakhropov2026-04-181-4/+4
| | | | commit_hash:ad96dd850bafe1a39637e0298d41f7a7ef7d9549
* Allow to change (reduce) max queue size for common elastic queuekulikov2026-03-233-1/+28
| | | | | Add same method as in TFastElasticQueue, and test. commit_hash:0a2b618325e57c32fd269254a7dbe912849c3f10
* Switch to std atomicskulikov2026-03-204-29/+26
| | | | commit_hash:5d980b19ed177f3a4ce03ba7c7d89ab9d711b8e8
* suport MakeFuture<void>() and NewPromise<void>() callsilnurkh2026-03-033-9/+10
| | | | commit_hash:b9c2c02a676598c074017c07a95838e719690d32
* Return old implementation of GetWorkerThreadID. Do not persist threadId ↵akhropov2026-02-102-23/+4
| | | | | | inside SetSparseFeatureBlock., commit_hash:0f88c1d2928f092c09638d654fca3baa6cb4f505
* move library/cpp/threading/atomic to library/cpp/deprecated/atomic_booltobo2026-01-295-87/+0
| | | | commit_hash:0981fb113212b130cb676672e125982188e4fd20
* TAtomic => std::atomic in library/cpp/threading/atomictobo2026-01-282-12/+9
| | | | commit_hash:d3337fcf8e16f28dc99d9466172f80b83d2fe569
* feat contrib: add futures subscription from contribkuzin572026-01-2622-0/+1935
| | | | | <https://nda.ya.ru/t/nesU8Ssd7StzZd> commit_hash:3b5733332bec71a4f2f26e6e878afb23dde01fe7
* Default CancellationToken should create only one instance of a Promiseswarmer2026-01-261-1/+5
| | | | | The NewPromise() function should not be called if the singleton has already been constructed. commit_hash:9e3b6c8908bbef648bf52ca2506ff0ae03ed0530
* Intermediate changesrobot-piglet2026-01-263-0/+65
| | | | commit_hash:4373219e5a3e59d3b6020a500b3953d735a28ef0
* cosmetics: use std::move() + constexpr + make argument name consistent with ↵tobo2026-01-241-7/+7
| | | | | | declaration commit_hash:6060ce65f9cdc998b9763fcc429bdd79188f522b
* TAtomic => std::atomic in library/cpp/threading/local_executortobo2026-01-232-36/+35
| | | | commit_hash:1e6b73c17aaaf69b19ff38a4b20246c45aeb3266
* TAtomic => std::atomic in library/cpp/threading/cron + cosmeticstobo2026-01-223-20/+18
| | | | commit_hash:3705bbac91a604b06838ca310e992f1b7728426d
* TAtomic => std::atomic in skip_listtobo2026-01-192-33/+18
| | | | commit_hash:ff28a92c3529ec57ec4b96b5c082146783d5bd39
* [trivial] store pointer inside atomictobo2026-01-151-5/+4
| | | | commit_hash:926ebc3875638338cbe9de01ababc1de0325eef6
* use std::atomic instead of TAtomictobo2026-01-143-27/+22
| | | | | replace TAtomic usage with std::atomic commit_hash:14c2a2e60040d84ba42fc8b90adbe9e4aad447d4
* Import RealAtomicSharedPtr to YDB GitHubzaspa942025-12-242-0/+425
| | | | commit_hash:4eb45cf77e018372f53f0b0a9ad069d27bdcfe24
* Intermediate changesrobot-piglet2025-12-181-2/+2
| | | | commit_hash:c4281bc281cdaef6bf0188500e82848c582cc5ad
* Intermediate changesrobot-piglet2025-12-171-4/+24
| | | | commit_hash:b8e5120d089fefb3429f136699614ed9ea813c21
* Use generic thread-local value for kernel/groupattrs, crash context and ↵kulikov2025-11-283-18/+44
| | | | | | | | | | | | | eventlog scope - fix StdThreadLocalImpl -- make static state refcounted, there is no guarantee that static fields will outlive threads or TThreadLocalValues; - replace thread local values to generic local storage value in some places; - call runtime Init and replace local values factory; - don't disable NCurrentThreadEventlog for ytxx runtime, it should now work; - ensure generic local storage values are allocated after runtime init; - use function-scope static variables to prevent issues with order of construction and destruction; - basesearch now almost works with coroutines (with NProfile disabled). commit_hash:7fde81591b0dbc3a53b8d1cb11bb96930a2e9a80
* Switch generic tls to thread_local-based implkulikov2025-11-261-1/+1
| | | | | After this, it becomes possible to zerodiff replace thread\_local variables with generic local values. Replace default TThreadLocal with generic will lead to it's destruction on thread exit, but it seems to be more correct behavior (e.g., avoid leaks on thread pool restart). commit_hash:6e5a0908ca239c1bac3ce6ba47de9e53290d6211
* TThreadLocalValue over standard thread_localskulikov2025-11-251-0/+122
| | | | | | | | | | | | | | Current TThreadLocal implementation doesn't destroy objects on thread exit (so we can't replace thread\_local tls value with it, and with TGenericLocalValue too), standard thread\_local values can't be class members. So try to reimplement TThreadLocalValue: - instead of adressing by thread id, address objects by uniq object id in thread\_local deque of all objects of current type; - use hashmap of all existing perthread deques to destroy objects with their TThreadLocal; - try to make object ids flat; - no complex lookup inside and no contention between tls.Get calls; - ShortLivedThreads ut now works; - some fixes in Trace ut, make threads outlive tls value; - benchmark results <https://nda.ya.ru/t/agWa9PW67NYAAK>, looks better than all others; - probably should switch to this implementation by default and remove old. commit_hash:262ce4d363751f577373a452a0c2c84d1fe5b79c
* Generic thread (yt fiber, etc) local storagekulikov2025-11-183-1/+109
| | | | commit_hash:cc357d273b7ce5c911d194dd51fae5668877693c
* Better commentthegeorg2025-11-071-1/+5
| | | | commit_hash:27b70d710c76793e58a4ed81dcd053907e389d85
* Try to prevent slicing in `co_return ex;`thegeorg2025-11-062-1/+11
| | | | commit_hash:348f2fb14a4a93cfa3c8504419d021c1f41e4b8f
* ysize -> size.akhropov2025-10-111-1/+1
| | | | commit_hash:5be5816fa0d06087b51636b3acfaf53350e750da
* Fix a potential memory leakakhropov2025-10-111-2/+2
| | | | commit_hash:17b4088b80f1a7446525ed8eebf0566b3e3a7888
* Add return lvalue test (and fix corresponding bugs)thegeorg2025-07-162-2/+7
| | | | commit_hash:f776eaac24e9bbe1abac58a171d9895556c43dd8
* coroutine_traits: Implicitly convert returned std::exception into erroneous ↵thegeorg2025-07-152-21/+89
| | | | | | TFuture commit_hash:80a673361a58719a241d3536cd4ffdd7d1a274ea
* Fix co_await argument dependent lookup for TFuture<T>snaury2025-07-014-16/+84
| | | | commit_hash:d3da906e0b3f303ead8bf1257a3cdceed2778d90
* Upver wine 10.8nechda2025-06-192-3/+1
| | | | commit_hash:db0a0308d356c8dca2520f3881de2615edcc4455
* Fix object destruction order when using TFuture<T> coroutinessnaury2025-06-193-42/+157
| | | | commit_hash:683c797584872e45e8df2ad7c663f1f1ebb253e3
* TTryGuard for queue locknae2022025-06-041-39/+58
| | | | commit_hash:027b7f086dcb0c574896ea5bd2c4958bf82914cf
* rm unused includes + fix memory_ordertobo2025-05-311-3/+1
| | | | commit_hash:bb222740eb5e56281bc138da43a8480640c40489
* AtomicTryLock() / AtomicUnlock() => TSpinLocktobo2025-05-301-27/+17
| | | | commit_hash:d6f16e427045049e4e5815d09a949cc721a20c79
* Intermediate changesrobot-piglet2025-04-141-28/+30
| | | | commit_hash:6452cbd39bd37ef1f2bd6be70bf9ceb91fb08a26
* List captured variables explicitly when 'this' has been implicitly captured ↵akhropov2025-04-102-4/+4
| | | | | | to avoid compiler warnings. commit_hash:6dda5bad9e3d887f91817bd4fdab95b66f3db001
* Fix TTbbLocalExecutor::GetWorkerThreadId. Enable ↵akhropov2025-04-072-4/+23
| | | | | | test_fit_on_scipy_sparse_spmatrix on Windows. commit_hash:c52cdc5529aff5cda1cbd11be2852647736ceb49
* More detailed description of GetWorkerThreadId. Remove comments duplicationakhropov2025-04-062-3/+5
| | | | commit_hash:19ac2b49b9bb7ac988b229e4d5c4c4ed6f75b138
* Add more IWYU export pragmas in library/*vadim-xd2025-04-061-0/+2
| | | | | Followup for rXXXXXX - reduce false-positives of include cleaner commit_hash:03bb3b1817067ed576faa57c597737b01d63d2e4
* [library/cpp/threading] Add convenience methods to schedule functions in ↵sskvor2025-03-243-62/+167
| | | | | | TTaskScheduler commit_hash:b8c3ae8e8ca6b0fea0bbf820f40513da41a242f8
* Fix cancellation in unifetcherjolex0072025-02-274-0/+257
| | | | commit_hash:909fa7aadbf673448dbc709b19d2088963b40404
* [libray/cpp/threading] Fix typosskvor2024-11-051-3/+3
| | | | commit_hash:f76f3edfa160fba90d0f8d594211fa35c6eb6077
* Intermediate changesrobot-piglet2024-10-151-0/+1
| | | | commit_hash:a9d505ad0eca8d52e322f9b3f5daaa1968f65b7b
* fix tsan warnings in library/cpp/threading unit testskulikov2024-09-121-5/+5
| | | | | | | | | - blocking_counter: fix destroy order; - thread_local: Head_.load must use std::memory_order_acquire to match memory_order_release in compare_exchange and ensure all writes are visible; also fix always null node value in first compare_exchange call; - work_stealing: use atomics. commit_hash:53f01a16bb40dd3eb890b0eb60388ecb0ce9c908
* Fix LSP in future-inl.hk-vukolov2024-08-191-0/+1
| | | | 71ff0471827f8bde6feb9549ead39faefb7f9b0f
* Intermediate changesrobot-piglet2024-08-062-16/+60
|
* Intermediate changesrobot-piglet2024-08-021-29/+33
|
* Intermediate changesrobot-piglet2024-08-013-0/+201
|
* Intermediate changesrobot-piglet2024-07-295-0/+195
|