Make thread_local_caching_allocator thread safe

Pansysk75 · Pansysk75 · commit a3376f7b07ce · 2025-05-17T05:50:03.000-05:00
Signed-off-by: Pansysk75 &lt;Pansysk75@gmail.com&gt;
diff --git a/libs/core/allocator_support/include/hpx/allocator_support/thread_local_caching_allocator.hpp b/libs/core/allocator_support/include/hpx/allocator_support/thread_local_caching_allocator.hpp
@@ -87,20 +87,12 @@ namespace hpx::util {
                         throw std::bad_alloc();
                     }
                 }
-
-                ++allocated;
                 return p;
             }
 
             void deallocate(pointer p, size_type n) noexcept
             {
                 data.push(std::make_pair(p, n));
-                if (++deallocated > 2 * (allocated + 16))
-                {
-                    clear_cache();
-                    allocated = 0;
-                    deallocated = 0;
-                }
             }
 
         private:
@@ -115,8 +107,6 @@ namespace hpx::util {
 
             HPX_NO_UNIQUE_ADDRESS Allocator alloc;
             Stack<std::pair<T*, size_type>, Allocator> data;
-            std::size_t allocated = 0;
-            std::size_t deallocated = 0;
         };
 
         allocated_cache& cache()

Original file line number	Diff line number	Diff line change
`@@ -87,20 +87,12 @@ namespace hpx::util {`
`87`	`87`	`throw std::bad_alloc();`
`88`	`88`	`}`
`89`	`89`	`}`
`90`		`-`
`91`		`- ++allocated;`
`92`	`90`	`return p;`
`93`	`91`	`}`
`94`	`92`
`95`	`93`	`void deallocate(pointer p, size_type n) noexcept`
`96`	`94`	`{`
`97`	`95`	`data.push(std::make_pair(p, n));`
`98`		`- if (++deallocated > 2 * (allocated + 16))`
`99`		`- {`
`100`		`- clear_cache();`
`101`		`- allocated = 0;`
`102`		`- deallocated = 0;`
`103`		`- }`
`104`	`96`	`}`
`105`	`97`
`106`	`98`	`private:`
`@@ -115,8 +107,6 @@ namespace hpx::util {`
`115`	`107`
`116`	`108`	`HPX_NO_UNIQUE_ADDRESS Allocator alloc;`
`117`	`109`	`Stack<std::pair<T*, size_type>, Allocator> data;`
`118`		`- std::size_t allocated = 0;`
`119`		`- std::size_t deallocated = 0;`
`120`	`110`	`};`
`121`	`111`
`122`	`112`	`allocated_cache& cache()`