Add parallel_for based on fork_join tasks.

lib/pls/CMakeLists.txt

@@ -4,10 +4,13 @@ add_library(pls STATIC
 
 
         include/pls/algorithms/invoke_parallel.h
         include/pls/algorithms/invoke_parallel.h
         include/pls/algorithms/invoke_parallel_impl.h
         include/pls/algorithms/invoke_parallel_impl.h
+        include/pls/algorithms/parallel_for.h
+        include/pls/algorithms/parallel_for_impl.h
 
 
         include/pls/internal/base/spin_lock.h
         include/pls/internal/base/spin_lock.h
         include/pls/internal/base/tas_spin_lock.h src/internal/base/tas_spin_lock.cpp
         include/pls/internal/base/tas_spin_lock.h src/internal/base/tas_spin_lock.cpp
         include/pls/internal/base/ttas_spin_lock.h src/internal/base/ttas_spin_lock.cpp
         include/pls/internal/base/ttas_spin_lock.h src/internal/base/ttas_spin_lock.cpp
+        include/pls/internal/base/swmr_spin_lock.h src/internal/base/swmr_spin_lock.cpp
         include/pls/internal/base/thread.h src/internal/base/thread.cpp
         include/pls/internal/base/thread.h src/internal/base/thread.cpp
         include/pls/internal/base/thread_impl.h
         include/pls/internal/base/thread_impl.h
         include/pls/internal/base/barrier.h src/internal/base/barrier.cpp
         include/pls/internal/base/barrier.h src/internal/base/barrier.cpp
@@ -32,8 +35,7 @@ add_library(pls STATIC
         include/pls/internal/scheduling/run_on_n_threads_task.h src/internal/scheduling/run_on_n_threads_task.cpp
         include/pls/internal/scheduling/run_on_n_threads_task.h src/internal/scheduling/run_on_n_threads_task.cpp
         include/pls/internal/scheduling/fork_join_task.h src/internal/scheduling/fork_join_task.cpp
         include/pls/internal/scheduling/fork_join_task.h src/internal/scheduling/fork_join_task.cpp
         include/pls/internal/scheduling/scheduler_memory.h src/internal/scheduling/scheduler_memory.cpp
         include/pls/internal/scheduling/scheduler_memory.h src/internal/scheduling/scheduler_memory.cpp
-        include/pls/internal/scheduling/parallel_iterator_task.h
-        include/pls/internal/scheduling/parallel_iterator_task_impl.h
+        include/pls/internal/scheduling/parallel_iterator_task.h include/pls/internal/scheduling/parallel_iterator_task_impl.h
         src/internal/scheduling/parallel_iterator_task.cpp)
         src/internal/scheduling/parallel_iterator_task.cpp)
 
 
 # Add everything in `./include` to be in the include path of this project
 # Add everything in `./include` to be in the include path of this project
@@ -43,15 +45,15 @@ target_include_directories(pls
         $<BUILD_INTERFACE:${CMAKE_CURRENT_SOURCE_DIR}/include>
         $<BUILD_INTERFACE:${CMAKE_CURRENT_SOURCE_DIR}/include>
         PRIVATE
         PRIVATE
         ${CMAKE_CURRENT_SOURCE_DIR}/src # TODO: Set this up when we require private headers
         ${CMAKE_CURRENT_SOURCE_DIR}/src # TODO: Set this up when we require private headers
-)
+        )
 
 
 # Add cmake dependencies here if needed
 # Add cmake dependencies here if needed
 target_link_libraries(pls
 target_link_libraries(pls
         Threads::Threads # pthread support
         Threads::Threads # pthread support
-)
-if(EASY_PROFILER)
+        )
+if (EASY_PROFILER)
     target_link_libraries(pls easy_profiler)
     target_link_libraries(pls easy_profiler)
-endif()
+endif ()
 
 
 # Rules for istalling the library on a system
 # Rules for istalling the library on a system
 # ...binaries
 # ...binaries
@@ -61,7 +63,7 @@ INSTALL(TARGETS pls
         DESTINATION lib/pls
         DESTINATION lib/pls
         ARCHIVE
         ARCHIVE
         DESTINATION lib/pls
         DESTINATION lib/pls
-)
+        )
 # ...all headers in `include`
 # ...all headers in `include`
 INSTALL(
 INSTALL(
         DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}/include/pls
         DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}/include/pls

lib/pls/include/pls/internal/data_structures/work_stealing_deque.h

@@ -78,9 +78,6 @@ class work_stealing_deque {
   std::atomic<cas_integer> tail_;
   std::atomic<cas_integer> tail_;
   cas_integer previous_tail_;
   cas_integer previous_tail_;
 
 
-  base::spin_lock lock_{}; // TODO: Remove after debugging
-
-
  public:
  public:
   using state = aligned_stack::state;
   using state = aligned_stack::state;