Revert "deque.hpp: claim stolen slot before reading it"

This reverts commit 5b626121.

rt/include/typon/core/scheduler.hpp

@@ -32,7 +32,7 @@ namespace typon
     std::vector<std::thread> _thread;
     std::atomic_bool _done {false};
     fdt::lock_free::event_count<> _notifyer;
-    const uint _concurrency;
+    const uint _parallelism;
 
     static Scheduler & get() noexcept
     {
@@ -57,13 +57,13 @@ namespace typon
       return get()._deque[thread_id].pop();
     }
 
-    Scheduler(uint concurrency) noexcept
-      : _deque(concurrency + 1, Deque(concurrency + 1))
-      , _concurrency(concurrency)
+    Scheduler(uint parallelism) noexcept
+      : _deque(parallelism + 1)
+      , _parallelism(parallelism)
     {
-      thread_id = concurrency;
+      thread_id = parallelism;
 
-      for (uint id = 0; id < concurrency; id++)
+      for (uint id = 0; id < parallelism; id++)
       {
         _thread.emplace_back([this, id]() {
           thread_id = id;
@@ -117,9 +117,9 @@ namespace typon
 
     void explore_task(Task & task) noexcept
     {
-      for (uint i = 0; i < _concurrency * 2 + 1; i++)
+      for (uint i = 0; i < _parallelism * 2 + 1; i++)
       {
-        uint id = fdt::random::random() % _concurrency;
+        uint id = fdt::random::random() % _parallelism;
         if (id == thread_id)
         {
           task = _deque.back().steal();

rt/include/typon/fundamental/deque.hpp

@@ -2,7 +2,6 @@
 #define TYPON_FUNDAMENTAL_DEQUE_HPP_INCLUDED
 
 #include <atomic>
-#include <bit>
 #include <cstdint>
 #include <memory>
 #include <type_traits>
@@ -33,16 +32,9 @@ namespace typon::fdt::lock_free
     std::atomic<u64> _top {1};
     std::atomic<u64> _bottom {1};
     std::atomic<array_type *> _array;
-    const unsigned int _concurrency;
 
-    deque(unsigned int concurrency) noexcept
-      : _array(new array_type(std::bit_width(concurrency) + 1))
-      , _concurrency(concurrency)
-    {}
-
-    deque(const deque & other) noexcept
-      : _array(new array_type(std::bit_width(other._concurrency) + 1))
-      , _concurrency(other._concurrency)
+    deque(u8 bits = 2) noexcept
+      : _array(new array_type(bits))
     {}
 
     ~deque()
@@ -55,7 +47,7 @@ namespace typon::fdt::lock_free
       u64 bottom = _bottom.load(relaxed);
       u64 top = _top.load(acquire);
       array_type * array = _array.load(relaxed);
-      if (bottom - top > array->capacity() - _concurrency)
+      if (bottom - top > array->capacity() - 1)
       {
         array = array->grow(top, bottom);
         _array.store(array);
@@ -100,16 +92,12 @@ namespace typon::fdt::lock_free
       if (top < bottom)
       {
         array_type * array = _array.load(consume);
+        T x = array->get(top);
         if (!_top.compare_exchange_strong(top, top + 1, seq_cst, relaxed))
         {
           return { Abort };
         }
-        // NB: The original algorithm reads the slot before claiming it.
-        // We read it after. To make sure it isn't overwritten, the push
-        // operation leaves at least as many slots free as there are
-        // potentially concurrent stealers.
-        // This also means reading non-atomically is not a data race.
-        return { array->get(top) };
+        return { x };
       }
       return { Empty };
     }