Set parallel execution policy

Author: ruberith

demo/main.cpp

@@ -152,13 +152,13 @@ void
 advect()
 {
 #ifdef _MSC_VER
-	concurrency::parallel_for_each
+	concurrency::parallel_for_each(
 #elif defined(__APPLE__) && defined(__clang__)
-	std::for_each
+	std::for_each(oneapi::dpl::execution::par,
 #else
-	__gnu_parallel::for_each
+	__gnu_parallel::for_each(
 #endif
-	(positions.begin(), positions.end(), [&](std::array<Real, 3>& x)
+	positions.begin(), positions.end(), [&](std::array<Real, 3>& x)
 	{
 		std::array<Real, 3> v = enright_velocity_field(x);
 		x[0] += static_cast<Real>(0.005) * v[0];

include/Config.h

@@ -15,6 +15,7 @@ namespace CompactNSearch
 #ifdef _MSC_VER
 	#include <ppl.h>
 #elif defined(__APPLE__) && defined(__clang__)
+	#include <oneapi/dpl/execution>
 	#include <oneapi/dpl/algorithm>
 #else
 	#include <parallel/algorithm>

src/CompactNSearch.cpp

@@ -235,13 +235,13 @@ NeighborhoodSearch::update_point_sets()
 
 	// Precompute cell indices.
 #ifdef _MSC_VER
-	concurrency::parallel_for_each
+	concurrency::parallel_for_each(
 #elif defined(__APPLE__) && defined(__clang__)
-	std::for_each
+	std::for_each(oneapi::dpl::execution::par,
 #else
-	__gnu_parallel::for_each
+	__gnu_parallel::for_each(
 #endif
-	(m_point_sets.begin(), m_point_sets.end(), [&](PointSet& d)
+	m_point_sets.begin(), m_point_sets.end(), [&](PointSet& d)
 	{
 		if (d.is_dynamic()) 
 		{
@@ -316,13 +316,13 @@ NeighborhoodSearch::erase_empty_entries(std::vector<unsigned int> const& to_dele
 
 	// Perform neighborhood search.
 #ifdef _MSC_VER
-	concurrency::parallel_for_each
+	concurrency::parallel_for_each(
 #elif defined(__APPLE__) && defined(__clang__)
-	std::for_each
+	std::for_each(oneapi::dpl::execution::par,
 #else
-	__gnu_parallel::for_each
+	__gnu_parallel::for_each(
 #endif
-	(kvps.begin(), kvps.end(), [&](std::pair<HashKey const, unsigned int>* kvp_)
+	kvps.begin(), kvps.end(), [&](std::pair<HashKey const, unsigned int>* kvp_)
 	{
 		auto& kvp = *kvp_;
 
@@ -416,13 +416,13 @@ NeighborhoodSearch::query()
 
 	// Perform neighborhood search.
 #ifdef _MSC_VER
-	concurrency::parallel_for_each
+	concurrency::parallel_for_each(
 #elif defined(__APPLE__) && defined(__clang__)
-	std::for_each
+	std::for_each(oneapi::dpl::execution::par,
 #else
-	__gnu_parallel::for_each
+	__gnu_parallel::for_each(
 #endif
-	(kvps.begin(), kvps.end(), [&](std::pair<HashKey const, unsigned int> const* kvp_)
+	kvps.begin(), kvps.end(), [&](std::pair<HashKey const, unsigned int> const* kvp_)
 	{
 		auto const& kvp = *kvp_;
 		HashEntry const& entry = m_entries[kvp.second];
@@ -478,13 +478,13 @@ NeighborhoodSearch::query()
 	std::vector<Spinlock> entry_locks(m_entries.size());
 
 #ifdef _MSC_VER
-	concurrency::parallel_for_each
+	concurrency::parallel_for_each(
 #elif defined(__APPLE__) && defined(__clang__)
-	std::for_each
+	std::for_each(oneapi::dpl::execution::par,
 #else
-	__gnu_parallel::for_each
+	__gnu_parallel::for_each(
 #endif
-	(kvps.begin(), kvps.end(), [&](std::pair<HashKey const, unsigned int> const* kvp_)
+	kvps.begin(), kvps.end(), [&](std::pair<HashKey const, unsigned int> const* kvp_)
 	{
 		auto const& kvp = *kvp_;
 		HashEntry const& entry = m_entries[kvp.second];