2016-03-04 13:59:43 +00:00
|
|
|
|
2017-09-20 08:16:26 +00:00
|
|
|
// This work derives from Vittorio Romeo's code used for cppcon 2015 licensed
|
|
|
|
// under the Academic Free License.
|
2016-03-15 10:29:13 +00:00
|
|
|
// His code is available here: https://github.com/SuperV1234/cppcon2015
|
|
|
|
|
|
|
|
|
2016-03-04 13:59:43 +00:00
|
|
|
#ifndef EC_MANAGER_HPP
|
|
|
|
#define EC_MANAGER_HPP
|
|
|
|
|
2016-03-13 09:07:49 +00:00
|
|
|
#define EC_INIT_ENTITIES_SIZE 256
|
|
|
|
#define EC_GROW_SIZE_AMOUNT 256
|
2016-03-05 14:33:24 +00:00
|
|
|
|
|
|
|
#include <cstddef>
|
2016-04-20 13:18:25 +00:00
|
|
|
#include <vector>
|
2016-03-05 14:33:24 +00:00
|
|
|
#include <tuple>
|
2016-03-13 09:07:49 +00:00
|
|
|
#include <utility>
|
2016-09-20 11:07:28 +00:00
|
|
|
#include <functional>
|
2016-09-21 12:01:48 +00:00
|
|
|
#include <map>
|
2017-07-13 07:13:37 +00:00
|
|
|
#include <unordered_map>
|
2016-09-21 12:01:48 +00:00
|
|
|
#include <set>
|
|
|
|
#include <unordered_set>
|
2017-07-13 07:13:37 +00:00
|
|
|
#include <algorithm>
|
2017-10-06 03:47:05 +00:00
|
|
|
#include <thread>
|
2017-11-09 12:10:01 +00:00
|
|
|
#include <mutex>
|
2016-03-05 14:33:24 +00:00
|
|
|
|
2017-11-10 04:19:50 +00:00
|
|
|
#ifndef NDEBUG
|
|
|
|
#include <iostream>
|
|
|
|
#endif
|
|
|
|
|
2016-03-05 14:33:24 +00:00
|
|
|
#include "Meta/Combine.hpp"
|
2016-04-20 12:59:47 +00:00
|
|
|
#include "Meta/Matching.hpp"
|
2017-11-15 06:36:04 +00:00
|
|
|
#include "Meta/ForEachWithIndex.hpp"
|
|
|
|
#include "Meta/ForEachDoubleTuple.hpp"
|
2016-03-05 14:33:24 +00:00
|
|
|
#include "Bitset.hpp"
|
|
|
|
|
2016-03-04 13:59:43 +00:00
|
|
|
namespace EC
|
|
|
|
{
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Manages an EntityComponent system.
|
|
|
|
|
2017-09-20 08:16:26 +00:00
|
|
|
EC::Manager must be created with a list of all used Components and all
|
|
|
|
used tags.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
|
|
|
Note that all components must have a default constructor.
|
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
EC::Manager<TypeList<C0, C1, C2>, TypeList<T0, T1>> manager;
|
|
|
|
\endcode
|
|
|
|
*/
|
2016-03-05 14:33:24 +00:00
|
|
|
template <typename ComponentsList, typename TagsList>
|
2016-03-04 13:59:43 +00:00
|
|
|
struct Manager
|
|
|
|
{
|
|
|
|
public:
|
|
|
|
using Combined = EC::Meta::Combine<ComponentsList, TagsList>;
|
2016-03-05 14:33:24 +00:00
|
|
|
using BitsetType = EC::Bitset<ComponentsList, TagsList>;
|
|
|
|
|
2016-03-13 09:07:49 +00:00
|
|
|
private:
|
|
|
|
template <typename... Types>
|
|
|
|
struct Storage
|
|
|
|
{
|
|
|
|
using type = std::tuple<std::vector<Types>... >;
|
|
|
|
};
|
2017-07-13 07:13:37 +00:00
|
|
|
using ComponentsStorage =
|
|
|
|
typename EC::Meta::Morph<ComponentsList, Storage<> >::type;
|
2016-03-13 09:07:49 +00:00
|
|
|
// Entity: isAlive, dataIndex, ComponentsTags Info
|
|
|
|
using EntitiesTupleType = std::tuple<bool, std::size_t, BitsetType>;
|
|
|
|
using EntitiesType = std::vector<EntitiesTupleType>;
|
|
|
|
|
|
|
|
EntitiesType entities;
|
|
|
|
ComponentsStorage componentsStorage;
|
|
|
|
std::size_t currentCapacity = 0;
|
|
|
|
std::size_t currentSize = 0;
|
|
|
|
|
|
|
|
public:
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Initializes the manager with a default capacity.
|
|
|
|
|
|
|
|
The default capacity is set with macro EC_INIT_ENTITIES_SIZE,
|
|
|
|
and will grow by amounts of EC_GROW_SIZE_AMOUNT when needed.
|
|
|
|
*/
|
2016-03-05 14:33:24 +00:00
|
|
|
Manager()
|
|
|
|
{
|
2016-03-13 09:07:49 +00:00
|
|
|
resize(EC_INIT_ENTITIES_SIZE);
|
|
|
|
}
|
|
|
|
|
|
|
|
private:
|
|
|
|
void resize(std::size_t newCapacity)
|
|
|
|
{
|
|
|
|
if(currentCapacity >= newCapacity)
|
|
|
|
{
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
EC::Meta::forEach<ComponentsList>([this, newCapacity] (auto t) {
|
2017-07-13 07:13:37 +00:00
|
|
|
std::get<std::vector<decltype(t)> >(
|
|
|
|
this->componentsStorage).resize(newCapacity);
|
2016-03-13 09:07:49 +00:00
|
|
|
});
|
2016-03-05 14:33:24 +00:00
|
|
|
|
2016-03-13 09:07:49 +00:00
|
|
|
entities.resize(newCapacity);
|
|
|
|
for(std::size_t i = currentCapacity; i < newCapacity; ++i)
|
2016-03-05 14:33:24 +00:00
|
|
|
{
|
2016-03-13 09:07:49 +00:00
|
|
|
entities[i] = std::make_tuple(false, i, BitsetType{});
|
2016-03-05 14:33:24 +00:00
|
|
|
}
|
2016-03-13 09:07:49 +00:00
|
|
|
|
|
|
|
currentCapacity = newCapacity;
|
2016-03-05 14:33:24 +00:00
|
|
|
}
|
|
|
|
|
2016-03-13 09:07:49 +00:00
|
|
|
public:
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Adds an entity to the system, returning the ID of the entity.
|
|
|
|
|
|
|
|
WARNING: The ID of an entity may change after calls to cleanup().
|
|
|
|
Usage of entity IDs should be safe during initialization.
|
2017-07-13 07:13:37 +00:00
|
|
|
Otherwise, only use the ID given during usage of
|
|
|
|
forMatchingSignature().
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
2016-03-05 14:33:24 +00:00
|
|
|
std::size_t addEntity()
|
|
|
|
{
|
2016-03-13 09:07:49 +00:00
|
|
|
if(currentSize == currentCapacity)
|
|
|
|
{
|
|
|
|
resize(currentCapacity + EC_GROW_SIZE_AMOUNT);
|
|
|
|
}
|
|
|
|
|
|
|
|
std::get<bool>(entities[currentSize]) = true;
|
|
|
|
|
|
|
|
return currentSize++;
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Marks an entity for deletion.
|
|
|
|
|
|
|
|
A deleted Entity is not actually deleted until cleanup() is called.
|
2017-07-13 07:13:37 +00:00
|
|
|
While an Entity is "deleted" but still in the system, calls to
|
|
|
|
forMatchingSignature() will ignore the Entity.
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
|
|
|
void deleteEntity(const std::size_t& index)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
std::get<bool>(entities.at(index)) = false;
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
|
|
|
|
/*!
|
|
|
|
\brief Checks if the Entity with the given ID is in the system.
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
Note that deleted Entities that haven't yet been cleaned up
|
|
|
|
(via cleanup()) are considered still in the system.
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
|
|
|
bool hasEntity(const std::size_t& index) const
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
return index < currentSize;
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
|
|
|
|
/*!
|
|
|
|
\brief Checks if the Entity is not marked as deleted.
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
Note that invalid Entities (Entities where calls to hasEntity()
|
|
|
|
returns false) will return false.
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
|
|
|
bool isAlive(const std::size_t& index) const
|
2016-03-14 09:25:38 +00:00
|
|
|
{
|
2016-03-14 11:01:55 +00:00
|
|
|
return hasEntity(index) && std::get<bool>(entities.at(index));
|
2016-03-14 09:25:38 +00:00
|
|
|
}
|
|
|
|
|
2017-11-03 08:11:20 +00:00
|
|
|
/*!
|
|
|
|
\brief Returns the current size or number of entities in the system.
|
|
|
|
|
|
|
|
Note that this size includes entities that have been marked for
|
|
|
|
deletion but not yet cleaned up by the cleanup function.
|
|
|
|
*/
|
|
|
|
std::size_t getCurrentSize() const
|
|
|
|
{
|
|
|
|
return currentSize;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
\brief Returns the current capacity or number of entities the system
|
|
|
|
can hold.
|
|
|
|
|
|
|
|
Note that when capacity is exceeded, the capacity is increased by
|
|
|
|
EC_GROW_SIZE_AMOUNT.
|
|
|
|
*/
|
|
|
|
std::size_t getCurrentCapacity() const
|
|
|
|
{
|
|
|
|
return currentCapacity;
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Returns a const reference to an Entity's info.
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
An Entity's info is a std::tuple with a bool, std::size_t, and a
|
|
|
|
bitset.
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
\n The bool determines if the Entity is alive.
|
|
|
|
\n The std::size_t is the ID to this Entity's data in the system.
|
|
|
|
\n The bitset shows what Components and Tags belong to the Entity.
|
|
|
|
*/
|
|
|
|
const EntitiesTupleType& getEntityInfo(const std::size_t& index) const
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
return entities.at(index);
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
2017-07-13 07:13:37 +00:00
|
|
|
\brief Returns a reference to a component belonging to the given
|
|
|
|
Entity.
|
|
|
|
|
|
|
|
This function will return a reference to a Component regardless of
|
|
|
|
whether or not the Entity actually owns the reference. If the Entity
|
|
|
|
doesn't own the Component, changes to the Component will not affect
|
|
|
|
any Entity. It is recommended to use hasComponent() to determine if
|
|
|
|
the Entity actually owns that Component.
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
2016-03-13 09:07:49 +00:00
|
|
|
template <typename Component>
|
2016-09-20 11:31:56 +00:00
|
|
|
Component& getEntityData(const std::size_t& index)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2017-09-20 08:16:26 +00:00
|
|
|
return std::get<std::vector<Component> >(componentsStorage).at(
|
|
|
|
std::get<std::size_t>(entities.at(index)));
|
2016-03-13 09:07:49 +00:00
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
2017-07-13 07:13:37 +00:00
|
|
|
\brief Returns a reference to a component belonging to the given
|
|
|
|
Entity.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
|
|
|
Note that this function is the same as getEntityData().
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
This function will return a reference to a Component regardless of
|
|
|
|
whether or not the Entity actually owns the reference. If the Entity
|
|
|
|
doesn't own the Component, changes to the Component will not affect
|
|
|
|
any Entity. It is recommended to use hasComponent() to determine if
|
|
|
|
the Entity actually owns that Component.
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
2016-03-14 09:16:09 +00:00
|
|
|
template <typename Component>
|
2016-09-20 11:31:56 +00:00
|
|
|
Component& getEntityComponent(const std::size_t& index)
|
|
|
|
{
|
|
|
|
return getEntityData<Component>(index);
|
|
|
|
}
|
|
|
|
|
2017-09-20 08:16:26 +00:00
|
|
|
/*!
|
|
|
|
\brief Returns a const reference to a component belonging to the
|
|
|
|
given Entity.
|
|
|
|
|
|
|
|
This function will return a const reference to a Component
|
|
|
|
regardless of whether or not the Entity actually owns the reference.
|
|
|
|
If the Entity doesn't own the Component, changes to the Component
|
|
|
|
will not affect any Entity. It is recommended to use hasComponent()
|
|
|
|
to determine if the Entity actually owns that Component.
|
|
|
|
*/
|
|
|
|
template <typename Component>
|
|
|
|
const Component& getEntityData(const std::size_t& index) const
|
|
|
|
{
|
|
|
|
return std::get<std::vector<Component> >(componentsStorage).at(
|
|
|
|
std::get<std::size_t>(entities.at(index)));
|
|
|
|
}
|
|
|
|
|
|
|
|
/*!
|
|
|
|
\brief Returns a const reference to a component belonging to the
|
|
|
|
given Entity.
|
|
|
|
|
|
|
|
Note that this function is the same as getEntityData() (const).
|
|
|
|
|
|
|
|
This function will return a const reference to a Component
|
|
|
|
regardless of whether or not the Entity actually owns the reference.
|
|
|
|
If the Entity doesn't own the Component, changes to the Component
|
|
|
|
will not affect any Entity. It is recommended to use hasComponent()
|
|
|
|
to determine if the Entity actually owns that Component.
|
|
|
|
*/
|
|
|
|
template <typename Component>
|
|
|
|
const Component& getEntityComponent(const std::size_t& index) const
|
|
|
|
{
|
|
|
|
return getEntityData<Component>(index);
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
2017-07-13 07:13:37 +00:00
|
|
|
\brief Checks whether or not the given Entity has the given
|
|
|
|
Component.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
manager.hasComponent<C0>(entityID);
|
|
|
|
\endcode
|
|
|
|
*/
|
|
|
|
template <typename Component>
|
|
|
|
bool hasComponent(const std::size_t& index) const
|
2016-03-14 09:16:09 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
return std::get<BitsetType>(
|
|
|
|
entities.at(index)).template getComponentBit<Component>();
|
2016-03-14 09:16:09 +00:00
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Checks whether or not the given Entity has the given Tag.
|
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
manager.hasTag<T0>(entityID);
|
|
|
|
\endcode
|
|
|
|
*/
|
2016-03-14 09:16:09 +00:00
|
|
|
template <typename Tag>
|
2016-09-20 11:31:56 +00:00
|
|
|
bool hasTag(const std::size_t& index) const
|
2016-03-14 09:16:09 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
return std::get<BitsetType>(
|
|
|
|
entities.at(index)).template getTagBit<Tag>();
|
2016-03-14 09:16:09 +00:00
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Does garbage collection on Entities.
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
Does housekeeping on the vector containing Entities that will
|
|
|
|
result in entity IDs changing if some Entities were marked for
|
|
|
|
deletion.
|
|
|
|
|
2017-09-20 08:16:26 +00:00
|
|
|
<b>This function should be called periodically to correctly handle
|
|
|
|
deletion of entities.</b>
|
2017-09-28 07:05:05 +00:00
|
|
|
|
2017-10-31 04:25:27 +00:00
|
|
|
The queue returned by this function lists all entities that have
|
2017-09-28 07:05:05 +00:00
|
|
|
changed as a result of calling this function.
|
2017-10-31 04:25:27 +00:00
|
|
|
|
|
|
|
The first parameter in the tuple (bool) is true if the entity has
|
|
|
|
been relocated (entity id has changed) and is false if the entity
|
|
|
|
has been deleted.
|
|
|
|
|
|
|
|
The second parameter (size_t) is the original entity id of the
|
|
|
|
entity. If the previous parameter was false for deleted, then this
|
|
|
|
refers to the id of that deleted entity. If the previous parameter
|
|
|
|
was true for relocated, then this refers to the previous id of the
|
|
|
|
relocated entity
|
|
|
|
|
|
|
|
The third parameter (size_t) is the new entity id of the entity if
|
|
|
|
the entity was relocated. If the entity was deleted then this
|
|
|
|
parameter is undefined as it is not used in that case.
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
2017-09-28 07:05:05 +00:00
|
|
|
using CleanupReturnType =
|
2017-11-24 05:58:00 +00:00
|
|
|
std::vector<std::tuple<bool, std::size_t, std::size_t> >;
|
2017-09-28 07:05:05 +00:00
|
|
|
CleanupReturnType cleanup()
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2017-11-24 05:58:00 +00:00
|
|
|
CleanupReturnType changedVector;
|
2016-03-14 09:16:09 +00:00
|
|
|
if(currentSize == 0)
|
|
|
|
{
|
2017-11-24 05:58:00 +00:00
|
|
|
return changedVector;
|
2016-03-14 09:16:09 +00:00
|
|
|
}
|
|
|
|
|
2016-03-13 09:07:49 +00:00
|
|
|
std::size_t rhs = currentSize - 1;
|
|
|
|
std::size_t lhs = 0;
|
|
|
|
|
|
|
|
while(lhs < rhs)
|
|
|
|
{
|
2016-03-14 09:16:09 +00:00
|
|
|
while(!std::get<bool>(entities[rhs]))
|
|
|
|
{
|
|
|
|
if(rhs == 0)
|
|
|
|
{
|
|
|
|
currentSize = 0;
|
2017-11-24 05:58:00 +00:00
|
|
|
return changedVector;
|
2016-03-14 09:16:09 +00:00
|
|
|
}
|
2017-11-24 05:58:00 +00:00
|
|
|
changedVector.push_back(std::make_tuple(false, rhs, 0));
|
2016-08-30 08:34:34 +00:00
|
|
|
std::get<BitsetType>(entities[rhs]).reset();
|
2016-03-14 11:05:49 +00:00
|
|
|
--rhs;
|
2016-03-14 09:16:09 +00:00
|
|
|
}
|
|
|
|
if(lhs >= rhs)
|
|
|
|
{
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
else if(!std::get<bool>(entities[lhs]))
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
// lhs is marked for deletion
|
2017-09-28 07:05:05 +00:00
|
|
|
|
2017-10-31 05:10:21 +00:00
|
|
|
// store deleted and changed id to queue
|
2017-11-24 05:58:00 +00:00
|
|
|
changedVector.push_back(std::make_tuple(false, lhs, 0));
|
|
|
|
changedVector.push_back(std::make_tuple(true, rhs, lhs));
|
2017-09-28 07:05:05 +00:00
|
|
|
|
2016-03-13 09:07:49 +00:00
|
|
|
// swap lhs entity with rhs entity
|
2016-03-14 09:16:09 +00:00
|
|
|
std::swap(entities[lhs], entities.at(rhs));
|
2016-03-13 09:07:49 +00:00
|
|
|
|
2016-03-14 02:39:37 +00:00
|
|
|
// clear deleted bitset
|
|
|
|
std::get<BitsetType>(entities[rhs]).reset();
|
|
|
|
|
2016-03-13 09:07:49 +00:00
|
|
|
// inc/dec pointers
|
|
|
|
++lhs; --rhs;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
++lhs;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
currentSize = rhs + 1;
|
2017-09-28 07:05:05 +00:00
|
|
|
|
2017-11-24 05:58:00 +00:00
|
|
|
return changedVector;
|
2016-03-13 09:07:49 +00:00
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Adds a component to the given Entity.
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
Additional parameters given to this function will construct the
|
|
|
|
Component with those parameters.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
Note that if the Entity already has the same component, then it
|
|
|
|
will be overwritten by the newly created Component with the given
|
|
|
|
arguments.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
struct C0
|
|
|
|
{
|
|
|
|
// constructor is compatible as a default constructor
|
|
|
|
C0(int a = 0, char b = 'b') :
|
|
|
|
a(a), b(b)
|
|
|
|
{}
|
|
|
|
|
|
|
|
int a;
|
|
|
|
char b;
|
|
|
|
}
|
|
|
|
|
|
|
|
manager.addComponent<C0>(entityID, 10, 'd');
|
|
|
|
\endcode
|
|
|
|
*/
|
2016-03-13 09:07:49 +00:00
|
|
|
template <typename Component, typename... Args>
|
2016-09-20 11:31:56 +00:00
|
|
|
void addComponent(const std::size_t& entityID, Args&&... args)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2016-03-14 09:25:38 +00:00
|
|
|
if(!hasEntity(entityID) || !isAlive(entityID))
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2016-04-06 10:32:30 +00:00
|
|
|
Component component(std::forward<Args>(args)...);
|
2016-03-13 09:07:49 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
std::get<BitsetType>(
|
|
|
|
entities[entityID]
|
|
|
|
).template getComponentBit<Component>() = true;
|
|
|
|
|
|
|
|
std::get<std::vector<Component> >(
|
|
|
|
componentsStorage
|
|
|
|
)[std::get<std::size_t>(entities[entityID])] = std::move(component);
|
2016-03-13 09:07:49 +00:00
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Removes the given Component from the given Entity.
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
If the Entity does not have the Component given, nothing will
|
|
|
|
change.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
manager.removeComponent<C0>(entityID);
|
|
|
|
\endcode
|
|
|
|
*/
|
2016-03-13 09:07:49 +00:00
|
|
|
template <typename Component>
|
2016-09-20 11:31:56 +00:00
|
|
|
void removeComponent(const std::size_t& entityID)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2016-03-14 09:25:38 +00:00
|
|
|
if(!hasEntity(entityID) || !isAlive(entityID))
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
std::get<BitsetType>(
|
|
|
|
entities[entityID]
|
|
|
|
).template getComponentBit<Component>() = false;
|
2016-03-13 09:07:49 +00:00
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Adds the given Tag to the given Entity.
|
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
manager.addTag<T0>(entityID);
|
|
|
|
\endcode
|
|
|
|
*/
|
2016-03-13 09:07:49 +00:00
|
|
|
template <typename Tag>
|
2016-09-20 11:31:56 +00:00
|
|
|
void addTag(const std::size_t& entityID)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2016-03-14 09:25:38 +00:00
|
|
|
if(!hasEntity(entityID) || !isAlive(entityID))
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
std::get<BitsetType>(
|
|
|
|
entities[entityID]
|
|
|
|
).template getTagBit<Tag>() = true;
|
2016-03-13 09:07:49 +00:00
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Removes the given Tag from the given Entity.
|
|
|
|
|
|
|
|
If the Entity does not have the Tag given, nothing will change.
|
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
manager.removeTag<T0>(entityID);
|
|
|
|
\endcode
|
|
|
|
*/
|
2016-03-13 09:07:49 +00:00
|
|
|
template <typename Tag>
|
2016-09-20 11:31:56 +00:00
|
|
|
void removeTag(const std::size_t& entityID)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2016-03-14 09:25:38 +00:00
|
|
|
if(!hasEntity(entityID) || !isAlive(entityID))
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
std::get<BitsetType>(
|
|
|
|
entities[entityID]
|
|
|
|
).template getTagBit<Tag>() = false;
|
2016-03-05 14:33:24 +00:00
|
|
|
}
|
2016-03-04 13:59:43 +00:00
|
|
|
|
|
|
|
private:
|
2016-03-13 09:07:49 +00:00
|
|
|
template <typename... Types>
|
|
|
|
struct ForMatchingSignatureHelper
|
|
|
|
{
|
|
|
|
template <typename CType, typename Function>
|
2017-07-13 07:13:37 +00:00
|
|
|
static void call(
|
|
|
|
const std::size_t& entityID,
|
|
|
|
CType& ctype,
|
|
|
|
Function&& function)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
|
|
|
function(
|
|
|
|
entityID,
|
|
|
|
ctype.template getEntityData<Types>(entityID)...
|
|
|
|
);
|
|
|
|
}
|
2016-09-20 11:07:28 +00:00
|
|
|
|
2017-11-14 04:11:32 +00:00
|
|
|
template <typename CType, typename Function>
|
|
|
|
static void callPtr(
|
|
|
|
const std::size_t& entityID,
|
|
|
|
CType& ctype,
|
|
|
|
Function* function)
|
|
|
|
{
|
|
|
|
(*function)(
|
|
|
|
entityID,
|
|
|
|
ctype.template getEntityData<Types>(entityID)...
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:07:28 +00:00
|
|
|
template <typename CType, typename Function>
|
2017-07-13 07:13:37 +00:00
|
|
|
void callInstance(
|
|
|
|
const std::size_t& entityID,
|
|
|
|
CType& ctype,
|
|
|
|
Function&& function) const
|
2016-09-20 11:07:28 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
ForMatchingSignatureHelper<Types...>::call(
|
|
|
|
entityID,
|
|
|
|
ctype,
|
|
|
|
std::forward<Function>(function));
|
2016-09-20 11:07:28 +00:00
|
|
|
}
|
2017-11-14 04:11:32 +00:00
|
|
|
|
|
|
|
template <typename CType, typename Function>
|
|
|
|
void callInstancePtr(
|
|
|
|
const std::size_t& entityID,
|
|
|
|
CType& ctype,
|
|
|
|
Function* function) const
|
|
|
|
{
|
|
|
|
ForMatchingSignatureHelper<Types...>::callPtr(
|
|
|
|
entityID,
|
|
|
|
ctype,
|
|
|
|
function);
|
|
|
|
}
|
2016-03-13 09:07:49 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
public:
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
2017-07-13 07:13:37 +00:00
|
|
|
\brief Calls the given function on all Entities matching the given
|
|
|
|
Signature.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
The function object given to this function must accept std::size_t
|
|
|
|
as its first parameter and Component references for the rest of the
|
|
|
|
parameters. Tags specified in the Signature are only used as
|
|
|
|
filters and will not be given as a parameter to the function.
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-10-06 03:47:05 +00:00
|
|
|
The second parameter is default 1 (not multi-threaded). If the
|
|
|
|
second parameter threadCount is set to a value greater than 1, then
|
|
|
|
threadCount threads will be used.
|
|
|
|
Note that multi-threading is based on splitting the task of calling
|
|
|
|
the function across sections of entities. Thus if there are only
|
|
|
|
a small amount of entities in the manager, then using multiple
|
|
|
|
threads may not have as great of a speed-up.
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
2017-07-13 07:13:37 +00:00
|
|
|
manager.forMatchingSignature<TypeList<C0, C1, T0>>([] (
|
|
|
|
std::size_t ID, C0& component0, C1& component1) {
|
2016-09-20 11:31:56 +00:00
|
|
|
// Lambda function contents here
|
2017-10-06 03:47:05 +00:00
|
|
|
},
|
|
|
|
4 // four threads
|
|
|
|
);
|
2016-09-20 11:31:56 +00:00
|
|
|
\endcode
|
2017-07-13 07:13:37 +00:00
|
|
|
Note, the ID given to the function is not permanent. An entity's ID
|
|
|
|
may change when cleanup() is called.
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
2016-03-13 09:07:49 +00:00
|
|
|
template <typename Signature, typename Function>
|
2017-10-06 03:47:05 +00:00
|
|
|
void forMatchingSignature(Function&& function,
|
|
|
|
std::size_t threadCount = 1)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
using SignatureComponents =
|
|
|
|
typename EC::Meta::Matching<Signature, ComponentsList>::type;
|
|
|
|
using Helper =
|
|
|
|
EC::Meta::Morph<
|
|
|
|
SignatureComponents,
|
|
|
|
ForMatchingSignatureHelper<> >;
|
|
|
|
|
|
|
|
BitsetType signatureBitset =
|
|
|
|
BitsetType::template generateBitset<Signature>();
|
2017-10-06 03:47:05 +00:00
|
|
|
if(threadCount <= 1)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2017-10-06 03:47:05 +00:00
|
|
|
for(std::size_t i = 0; i < currentSize; ++i)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2017-10-06 03:47:05 +00:00
|
|
|
if(!std::get<bool>(entities[i]))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2016-03-13 09:07:49 +00:00
|
|
|
|
2017-10-06 03:47:05 +00:00
|
|
|
if((signatureBitset & std::get<BitsetType>(entities[i]))
|
|
|
|
== signatureBitset)
|
|
|
|
{
|
|
|
|
Helper::call(i, *this,
|
|
|
|
std::forward<Function>(function));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
2017-10-06 03:58:49 +00:00
|
|
|
std::vector<std::thread> threads(threadCount);
|
2017-10-06 03:47:05 +00:00
|
|
|
std::size_t s = currentSize / threadCount;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = currentSize;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread([this, &function, &signatureBitset]
|
|
|
|
(std::size_t begin,
|
|
|
|
std::size_t end) {
|
|
|
|
for(std::size_t i = begin; i < end; ++i)
|
|
|
|
{
|
|
|
|
if(!std::get<bool>(this->entities[i]))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if((signatureBitset
|
|
|
|
& std::get<BitsetType>(entities[i]))
|
|
|
|
== signatureBitset)
|
|
|
|
{
|
|
|
|
Helper::call(i, *this,
|
|
|
|
std::forward<Function>(function));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
begin,
|
|
|
|
end);
|
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
2016-03-13 09:07:49 +00:00
|
|
|
{
|
2017-10-06 03:47:05 +00:00
|
|
|
threads[i].join();
|
2016-03-13 09:07:49 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2016-03-04 13:59:43 +00:00
|
|
|
|
2017-11-14 04:11:32 +00:00
|
|
|
/*!
|
|
|
|
\brief Calls the given function on all Entities matching the given
|
|
|
|
Signature.
|
|
|
|
|
|
|
|
The function pointer given to this function must accept std::size_t
|
|
|
|
as its first parameter and Component references for the rest of the
|
|
|
|
parameters. Tags specified in the Signature are only used as
|
|
|
|
filters and will not be given as a parameter to the function.
|
|
|
|
|
|
|
|
The second parameter is default 1 (not multi-threaded). If the
|
|
|
|
second parameter threadCount is set to a value greater than 1, then
|
|
|
|
threadCount threads will be used.
|
|
|
|
Note that multi-threading is based on splitting the task of calling
|
|
|
|
the function across sections of entities. Thus if there are only
|
|
|
|
a small amount of entities in the manager, then using multiple
|
|
|
|
threads may not have as great of a speed-up.
|
|
|
|
|
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
|
|
|
auto function = [] (std::size_t ID, C0& component0,
|
|
|
|
C1& component1) {
|
|
|
|
// Lambda function contents here
|
|
|
|
};
|
|
|
|
manager.forMatchingSignaturePtr<TypeList<C0, C1, T0>>(
|
|
|
|
&function, // ptr
|
|
|
|
4 // four threads
|
|
|
|
);
|
|
|
|
\endcode
|
|
|
|
Note, the ID given to the function is not permanent. An entity's ID
|
|
|
|
may change when cleanup() is called.
|
|
|
|
*/
|
|
|
|
template <typename Signature, typename Function>
|
|
|
|
void forMatchingSignaturePtr(Function* function,
|
|
|
|
std::size_t threadCount = 1)
|
|
|
|
{
|
|
|
|
using SignatureComponents =
|
|
|
|
typename EC::Meta::Matching<Signature, ComponentsList>::type;
|
|
|
|
using Helper =
|
|
|
|
EC::Meta::Morph<
|
|
|
|
SignatureComponents,
|
|
|
|
ForMatchingSignatureHelper<> >;
|
|
|
|
|
|
|
|
BitsetType signatureBitset =
|
|
|
|
BitsetType::template generateBitset<Signature>();
|
|
|
|
if(threadCount <= 1)
|
|
|
|
{
|
|
|
|
for(std::size_t i = 0; i < currentSize; ++i)
|
|
|
|
{
|
|
|
|
if(!std::get<bool>(entities[i]))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if((signatureBitset & std::get<BitsetType>(entities[i]))
|
|
|
|
== signatureBitset)
|
|
|
|
{
|
|
|
|
Helper::callPtr(i, *this, function);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
std::vector<std::thread> threads(threadCount);
|
|
|
|
std::size_t s = currentSize / threadCount;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = currentSize;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread([this, &function, &signatureBitset]
|
|
|
|
(std::size_t begin,
|
|
|
|
std::size_t end) {
|
|
|
|
for(std::size_t i = begin; i < end; ++i)
|
|
|
|
{
|
|
|
|
if(!std::get<bool>(this->entities[i]))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if((signatureBitset
|
|
|
|
& std::get<BitsetType>(entities[i]))
|
|
|
|
== signatureBitset)
|
|
|
|
{
|
|
|
|
Helper::callPtr(i, *this, function);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
begin,
|
|
|
|
end);
|
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
threads[i].join();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
2016-09-20 11:07:28 +00:00
|
|
|
private:
|
2017-11-14 04:51:24 +00:00
|
|
|
std::unordered_map<std::size_t, std::tuple<
|
|
|
|
BitsetType,
|
|
|
|
std::function<void(
|
|
|
|
std::size_t,
|
|
|
|
std::vector<std::size_t>)> > >
|
2017-09-20 08:16:26 +00:00
|
|
|
forMatchingFunctions;
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t functionIndex = 0;
|
2016-09-20 11:07:28 +00:00
|
|
|
|
|
|
|
public:
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Stores a function in the manager to be called later.
|
|
|
|
|
|
|
|
As an alternative to calling functions directly with
|
|
|
|
forMatchingSignature(), functions can be stored in the manager to
|
2017-07-12 13:02:02 +00:00
|
|
|
be called later with callForMatchingFunctions() and
|
2017-07-13 07:13:37 +00:00
|
|
|
callForMatchingFunction, and removed with
|
|
|
|
clearForMatchingFunctions() and removeForMatchingFunction().
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
The syntax for the Function is the same as with
|
|
|
|
forMatchingSignature().
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
Note that functions will be called in the same order they are
|
|
|
|
inserted if called by callForMatchingFunctions() unless the
|
|
|
|
internal functionIndex counter has wrapped around (is a
|
|
|
|
std::size_t). Calling clearForMatchingFunctions() will reset this
|
|
|
|
counter to zero.
|
2016-09-21 12:01:48 +00:00
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
2017-07-13 07:13:37 +00:00
|
|
|
manager.addForMatchingFunction<TypeList<C0, C1, T0>>([] (
|
|
|
|
std::size_t ID, C0& component0, C1& component1) {
|
2016-09-20 11:31:56 +00:00
|
|
|
// Lambda function contents here
|
|
|
|
});
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
// call all stored functions
|
|
|
|
manager.callForMatchingFunctions();
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
// remove all stored functions
|
|
|
|
manager.clearForMatchingFunctions();
|
2016-09-20 11:31:56 +00:00
|
|
|
\endcode
|
2016-09-21 12:01:48 +00:00
|
|
|
|
|
|
|
\return The index of the function, used for deletion with
|
|
|
|
deleteForMatchingFunction() or filtering with
|
2017-07-13 07:13:37 +00:00
|
|
|
keepSomeMatchingFunctions() or removeSomeMatchingFunctions(),
|
|
|
|
or calling with callForMatchingFunction().
|
2016-09-20 11:31:56 +00:00
|
|
|
*/
|
2016-09-20 11:07:28 +00:00
|
|
|
template <typename Signature, typename Function>
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t addForMatchingFunction(Function&& function)
|
2016-09-20 11:07:28 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
while(forMatchingFunctions.find(functionIndex)
|
|
|
|
!= forMatchingFunctions.end())
|
|
|
|
{
|
|
|
|
++functionIndex;
|
|
|
|
}
|
|
|
|
|
|
|
|
using SignatureComponents =
|
|
|
|
typename EC::Meta::Matching<Signature, ComponentsList>::type;
|
|
|
|
using Helper =
|
|
|
|
EC::Meta::Morph<
|
|
|
|
SignatureComponents,
|
|
|
|
ForMatchingSignatureHelper<> >;
|
2016-09-20 11:07:28 +00:00
|
|
|
|
|
|
|
Helper helper;
|
2017-07-13 07:13:37 +00:00
|
|
|
BitsetType signatureBitset =
|
|
|
|
BitsetType::template generateBitset<Signature>();
|
2016-09-20 11:07:28 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
forMatchingFunctions.emplace(std::make_pair(
|
|
|
|
functionIndex,
|
2017-11-14 04:51:24 +00:00
|
|
|
std::make_tuple(
|
|
|
|
signatureBitset,
|
|
|
|
[function, helper, this]
|
|
|
|
(std::size_t threadCount,
|
|
|
|
std::vector<std::size_t> matching)
|
2016-09-20 11:07:28 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
if(threadCount <= 1)
|
2016-09-20 11:07:28 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
for(auto eid : matching)
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
helper.callInstancePtr(eid, *this, &function);
|
2017-10-06 03:47:05 +00:00
|
|
|
}
|
2017-11-14 04:51:24 +00:00
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
std::vector<std::thread> threads(threadCount);
|
|
|
|
std::size_t s = matching.size() / threadCount;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++ i)
|
|
|
|
{
|
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = matching.size();
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread(
|
|
|
|
[this, &function, &helper]
|
|
|
|
(std::size_t begin,
|
|
|
|
std::size_t end) {
|
|
|
|
for(std::size_t i = begin; i < end; ++i)
|
|
|
|
{
|
|
|
|
helper.callInstancePtr(i, *this, &function);
|
|
|
|
}
|
|
|
|
},
|
|
|
|
begin, end);
|
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
threads[i].join();
|
2017-10-06 03:47:05 +00:00
|
|
|
}
|
|
|
|
}
|
2017-11-14 04:51:24 +00:00
|
|
|
})));
|
|
|
|
|
|
|
|
return functionIndex++;
|
|
|
|
}
|
|
|
|
|
|
|
|
private:
|
|
|
|
std::vector<std::vector<std::size_t> > getMatchingEntities(
|
|
|
|
std::vector<BitsetType*> bitsets, std::size_t threadCount = 1)
|
|
|
|
{
|
|
|
|
std::vector<std::vector<std::size_t> > matchingV(bitsets.size());
|
|
|
|
|
|
|
|
if(threadCount <= 1)
|
|
|
|
{
|
|
|
|
for(std::size_t i = 0; i < currentSize; ++i)
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
if(!isAlive(i))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
for(std::size_t j = 0; j < bitsets.size(); ++j)
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
if(((*bitsets[j]) & std::get<BitsetType>(entities[i]))
|
|
|
|
== (*bitsets[j]))
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
matchingV[j].push_back(i);
|
2017-10-06 03:47:05 +00:00
|
|
|
}
|
2017-11-14 04:51:24 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
std::vector<std::thread> threads(threadCount);
|
|
|
|
std::size_t s = currentSize / threadCount;
|
|
|
|
std::mutex mutex;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = currentSize;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread(
|
|
|
|
[this, &matchingV, &bitsets, &mutex]
|
|
|
|
(std::size_t begin, std::size_t end)
|
|
|
|
{
|
|
|
|
for(std::size_t j = begin; j < end; ++j)
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
if(!isAlive(j))
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
continue;
|
|
|
|
}
|
|
|
|
for(std::size_t k = 0; k < bitsets.size(); ++k)
|
|
|
|
{
|
|
|
|
if(((*bitsets[k]) &
|
|
|
|
std::get<BitsetType>(entities[j]))
|
|
|
|
== (*bitsets[k]))
|
2017-10-06 03:47:05 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
std::lock_guard<std::mutex> guard(mutex);
|
|
|
|
matchingV[k].push_back(j);
|
2017-10-06 03:47:05 +00:00
|
|
|
}
|
|
|
|
}
|
2017-11-14 04:51:24 +00:00
|
|
|
}
|
|
|
|
}, begin, end);
|
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
threads[i].join();
|
2016-09-20 11:07:28 +00:00
|
|
|
}
|
2017-11-14 04:51:24 +00:00
|
|
|
}
|
2016-09-21 12:01:48 +00:00
|
|
|
|
2017-11-14 04:51:24 +00:00
|
|
|
return matchingV;
|
2016-09-20 11:07:28 +00:00
|
|
|
}
|
|
|
|
|
2017-11-14 04:51:24 +00:00
|
|
|
public:
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Call all stored functions.
|
|
|
|
|
2017-10-06 03:47:05 +00:00
|
|
|
A second parameter can be optionally used to specify the number
|
|
|
|
of threads to use when calling the functions. Otherwise, this
|
|
|
|
function is by default not multi-threaded.
|
|
|
|
Note that multi-threading is based on splitting the task of calling
|
|
|
|
the functions across sections of entities. Thus if there are only
|
|
|
|
a small amount of entities in the manager, then using multiple
|
|
|
|
threads may not have as great of a speed-up.
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
2017-07-13 07:13:37 +00:00
|
|
|
manager.addForMatchingFunction<TypeList<C0, C1, T0>>([] (
|
|
|
|
std::size_t ID, C0& component0, C1& component1) {
|
2016-09-20 11:31:56 +00:00
|
|
|
// Lambda function contents here
|
|
|
|
});
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
// call all stored functions
|
|
|
|
manager.callForMatchingFunctions();
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-10-06 03:47:05 +00:00
|
|
|
// call all stored functions with 4 threads
|
|
|
|
manager.callForMatchingFunctions(4);
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
// remove all stored functions
|
|
|
|
manager.clearForMatchingFunctions();
|
2016-09-20 11:31:56 +00:00
|
|
|
\endcode
|
|
|
|
*/
|
2017-10-06 03:47:05 +00:00
|
|
|
void callForMatchingFunctions(std::size_t threadCount = 1)
|
2016-09-20 11:07:28 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
std::vector<BitsetType*> bitsets;
|
|
|
|
for(auto iter = forMatchingFunctions.begin();
|
|
|
|
iter != forMatchingFunctions.end();
|
|
|
|
++iter)
|
|
|
|
{
|
|
|
|
bitsets.push_back(&std::get<BitsetType>(iter->second));
|
|
|
|
}
|
|
|
|
|
|
|
|
std::vector<std::vector<std::size_t> > matching =
|
|
|
|
getMatchingEntities(bitsets, threadCount);
|
|
|
|
|
|
|
|
std::size_t i = 0;
|
|
|
|
for(auto iter = forMatchingFunctions.begin();
|
|
|
|
iter != forMatchingFunctions.end();
|
|
|
|
++iter)
|
2016-09-20 11:07:28 +00:00
|
|
|
{
|
2017-11-14 04:51:24 +00:00
|
|
|
std::get<1>(iter->second)(threadCount, matching[i++]);
|
2016-09-20 11:07:28 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-07-12 13:02:02 +00:00
|
|
|
/*!
|
|
|
|
\brief Call a specific stored function.
|
|
|
|
|
2017-10-06 03:47:05 +00:00
|
|
|
A second parameter can be optionally used to specify the number
|
|
|
|
of threads to use when calling the function. Otherwise, this
|
|
|
|
function is by default not multi-threaded.
|
|
|
|
Note that multi-threading is based on splitting the task of calling
|
|
|
|
the function across sections of entities. Thus if there are only
|
|
|
|
a small amount of entities in the manager, then using multiple
|
|
|
|
threads may not have as great of a speed-up.
|
|
|
|
|
2017-07-12 13:02:02 +00:00
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t id =
|
|
|
|
manager.addForMatchingFunction<TypeList<C0, C1, T0>>(
|
2017-07-12 13:02:02 +00:00
|
|
|
[] (std::size_t ID, C0& c0, C1& c1) {
|
|
|
|
// Lambda function contents here
|
|
|
|
});
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
// call the previously added function
|
|
|
|
manager.callForMatchingFunction(id);
|
2017-10-06 03:47:05 +00:00
|
|
|
|
|
|
|
// call the previously added function with 4 threads
|
|
|
|
manager.callForMatchingFunction(id, 4);
|
2017-07-12 13:02:02 +00:00
|
|
|
\endcode
|
|
|
|
|
|
|
|
\return False if a function with the given id does not exist.
|
|
|
|
*/
|
2017-10-06 03:47:05 +00:00
|
|
|
bool callForMatchingFunction(std::size_t id,
|
|
|
|
std::size_t threadCount = 1)
|
2017-07-12 13:02:02 +00:00
|
|
|
{
|
|
|
|
auto iter = forMatchingFunctions.find(id);
|
|
|
|
if(iter == forMatchingFunctions.end())
|
|
|
|
{
|
|
|
|
return false;
|
|
|
|
}
|
2017-11-14 04:51:24 +00:00
|
|
|
std::vector<std::vector<std::size_t> > matching =
|
|
|
|
getMatchingEntities(std::vector<BitsetType*>{
|
|
|
|
&std::get<BitsetType>(iter->second)}, threadCount);
|
|
|
|
std::get<1>(iter->second)(threadCount, matching[0]);
|
2017-07-12 13:02:02 +00:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
/*!
|
|
|
|
\brief Remove all stored functions.
|
|
|
|
|
2016-09-21 12:01:48 +00:00
|
|
|
Also resets the index counter of stored functions to 0.
|
|
|
|
|
2016-09-20 11:31:56 +00:00
|
|
|
Example:
|
|
|
|
\code{.cpp}
|
2017-07-13 07:13:37 +00:00
|
|
|
manager.addForMatchingFunction<TypeList<C0, C1, T0>>([] (
|
|
|
|
std::size_t ID, C0& component0, C1& component1) {
|
2016-09-20 11:31:56 +00:00
|
|
|
// Lambda function contents here
|
|
|
|
});
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
// call all stored functions
|
|
|
|
manager.callForMatchingFunctions();
|
2016-09-20 11:31:56 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
// remove all stored functions
|
|
|
|
manager.clearForMatchingFunctions();
|
2016-09-20 11:31:56 +00:00
|
|
|
\endcode
|
|
|
|
*/
|
2016-09-20 11:07:28 +00:00
|
|
|
void clearForMatchingFunctions()
|
|
|
|
{
|
|
|
|
forMatchingFunctions.clear();
|
2016-09-21 12:01:48 +00:00
|
|
|
functionIndex = 0;
|
|
|
|
}
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
/*!
|
|
|
|
\brief Removes a function that has the given id.
|
|
|
|
|
|
|
|
\return True if a function was erased.
|
|
|
|
*/
|
|
|
|
bool removeForMatchingFunction(std::size_t id)
|
|
|
|
{
|
|
|
|
return forMatchingFunctions.erase(id) == 1;
|
|
|
|
}
|
|
|
|
|
2016-09-21 12:01:48 +00:00
|
|
|
/*!
|
|
|
|
\brief Removes all functions that do not have the index specified
|
|
|
|
in argument "list".
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
The given List must be iterable.
|
|
|
|
This is the only requirement, so a set could also be given.
|
|
|
|
|
|
|
|
\return The number of functions deleted.
|
2016-09-21 12:01:48 +00:00
|
|
|
*/
|
|
|
|
template <typename List>
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t keepSomeMatchingFunctions(List list)
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t deletedCount = 0;
|
2017-09-20 08:16:26 +00:00
|
|
|
for(auto iter = forMatchingFunctions.begin();
|
|
|
|
iter != forMatchingFunctions.end();)
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-09-20 08:16:26 +00:00
|
|
|
if(std::find(list.begin(), list.end(), iter->first)
|
|
|
|
== list.end())
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-07-13 08:28:45 +00:00
|
|
|
iter = forMatchingFunctions.erase(iter);
|
|
|
|
++deletedCount;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
++iter;
|
2016-09-21 12:01:48 +00:00
|
|
|
}
|
|
|
|
}
|
2017-07-13 07:13:37 +00:00
|
|
|
|
|
|
|
return deletedCount;
|
2016-09-21 12:01:48 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/*!
|
|
|
|
\brief Removes all functions that do not have the index specified
|
|
|
|
in argument "list".
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
This function allows for passing an initializer list.
|
|
|
|
|
|
|
|
\return The number of functions deleted.
|
2016-09-21 12:01:48 +00:00
|
|
|
*/
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t keepSomeMatchingFunctions(
|
|
|
|
std::initializer_list<std::size_t> list)
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
return keepSomeMatchingFunctions<decltype(list)>(list);
|
2016-09-21 12:01:48 +00:00
|
|
|
}
|
|
|
|
|
2017-07-12 13:02:02 +00:00
|
|
|
/*!
|
2017-07-13 07:13:37 +00:00
|
|
|
\brief Removes all functions that do have the index specified
|
|
|
|
in argument "list".
|
2017-07-12 13:02:02 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
The given List must be iterable.
|
|
|
|
This is the only requirement, so a set could also be given.
|
2017-07-12 13:02:02 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
\return The number of functions deleted.
|
|
|
|
*/
|
|
|
|
template <typename List>
|
|
|
|
std::size_t removeSomeMatchingFunctions(List list)
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t deletedCount = 0;
|
|
|
|
for(auto listIter = list.begin();
|
|
|
|
listIter != list.end();
|
|
|
|
++listIter)
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
deletedCount += forMatchingFunctions.erase(*listIter);
|
2016-09-21 12:01:48 +00:00
|
|
|
}
|
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
return deletedCount;
|
2016-09-21 12:01:48 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/*!
|
2017-07-13 07:13:37 +00:00
|
|
|
\brief Removes all functions that do have the index specified
|
|
|
|
in argument "list".
|
|
|
|
|
|
|
|
This function allows for passing an initializer list.
|
2016-09-21 12:01:48 +00:00
|
|
|
|
2017-07-13 07:13:37 +00:00
|
|
|
\return The number of functions deleted.
|
2016-09-21 12:01:48 +00:00
|
|
|
*/
|
2017-07-13 07:13:37 +00:00
|
|
|
std::size_t removeSomeMatchingFunctions(
|
|
|
|
std::initializer_list<std::size_t> list)
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
return removeSomeMatchingFunctions<decltype(list)>(list);
|
2016-09-21 12:01:48 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/*!
|
|
|
|
\brief Deletes the specified function.
|
|
|
|
|
|
|
|
The index of a function is returned from addForMatchingFunction()
|
|
|
|
so there is no other way to get the index of a function.
|
2017-07-13 07:13:37 +00:00
|
|
|
|
|
|
|
\return True if function existed and has been deleted.
|
2016-09-21 12:01:48 +00:00
|
|
|
*/
|
2017-07-13 07:13:37 +00:00
|
|
|
bool deleteForMatchingFunction(std::size_t index)
|
2016-09-21 12:01:48 +00:00
|
|
|
{
|
2017-07-13 07:13:37 +00:00
|
|
|
return forMatchingFunctions.erase(index) == 1;
|
2016-09-20 11:07:28 +00:00
|
|
|
}
|
|
|
|
|
2017-11-09 12:10:01 +00:00
|
|
|
/*!
|
|
|
|
\brief Call multiple functions with mulitple signatures on all
|
|
|
|
living entities.
|
|
|
|
|
|
|
|
(Living entities as in entities that have not been marked for
|
|
|
|
deletion.)
|
|
|
|
|
|
|
|
This function requires the first template parameter to be a
|
|
|
|
EC::Meta::TypeList of signatures. Note that a signature is a
|
|
|
|
EC::Meta::TypeList of components and tags, meaning that SigList
|
|
|
|
is a TypeList of TypeLists.
|
|
|
|
|
|
|
|
The second template parameter can be inferred from the function
|
|
|
|
parameter which should be a tuple of functions. The function
|
|
|
|
at any index in the tuple should match with a signature of the
|
|
|
|
same index in the SigList. Behavior is undefined if there are
|
|
|
|
less functions than signatures.
|
|
|
|
|
|
|
|
See the Unit Test of this function in src/test/ECTest.cpp for
|
|
|
|
usage examples.
|
|
|
|
|
|
|
|
This function was created for the use case where there are many
|
|
|
|
entities in the system which can cause multiple calls to
|
|
|
|
forMatchingSignature to be slow due to the overhead of iterating
|
|
|
|
through the entire list of entities on each invocation.
|
|
|
|
This function instead iterates through all entities once,
|
|
|
|
storing matching entities in a vector of vectors (for each
|
|
|
|
signature and function pair) and then calling functions with
|
|
|
|
the matching list of entities.
|
|
|
|
|
|
|
|
Note that multi-threaded or not, functions will be called in order
|
|
|
|
of signatures. The first function signature pair will be called
|
|
|
|
first, then the second, third, and so on.
|
|
|
|
If this function is called with more than 1 thread specified, then
|
|
|
|
the order of entities called is not guaranteed. Otherwise entities
|
|
|
|
will be called in consecutive order by their ID.
|
|
|
|
*/
|
2017-11-15 06:36:04 +00:00
|
|
|
template <typename SigList, typename FTuple>
|
|
|
|
void forMatchingSignatures(
|
|
|
|
FTuple fTuple, const std::size_t threadCount = 1)
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
|
|
|
std::vector<std::vector<std::size_t> > multiMatchingEntities(
|
|
|
|
SigList::size);
|
|
|
|
BitsetType signatureBitsets[SigList::size];
|
|
|
|
|
|
|
|
// generate bitsets for each signature
|
2017-11-15 06:36:04 +00:00
|
|
|
EC::Meta::forEachWithIndex<SigList>(
|
|
|
|
[this, &signatureBitsets] (auto signature, const auto index) {
|
|
|
|
signatureBitsets[index] =
|
|
|
|
BitsetType::template generateBitset
|
|
|
|
<decltype(signature)>();
|
2017-11-09 12:10:01 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
// find and store entities matching signatures
|
|
|
|
if(threadCount <= 1)
|
|
|
|
{
|
|
|
|
for(std::size_t eid = 0; eid < currentSize; ++eid)
|
|
|
|
{
|
|
|
|
if(!isAlive(eid))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < SigList::size; ++i)
|
|
|
|
{
|
|
|
|
if((signatureBitsets[i]
|
|
|
|
& std::get<BitsetType>(entities[eid]))
|
|
|
|
== signatureBitsets[i])
|
|
|
|
{
|
|
|
|
multiMatchingEntities[i].push_back(eid);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
std::vector<std::thread> threads(threadCount);
|
2017-11-15 06:36:04 +00:00
|
|
|
std::mutex mutexes[SigList::size];
|
2017-11-09 12:10:01 +00:00
|
|
|
std::size_t s = currentSize / threadCount;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = currentSize;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread(
|
2017-11-15 06:36:04 +00:00
|
|
|
[this, &mutexes, &multiMatchingEntities, &signatureBitsets]
|
|
|
|
(std::size_t begin, std::size_t end)
|
|
|
|
{
|
|
|
|
for(std::size_t j = begin; j < end; ++j)
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
if(!isAlive(j))
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
for(std::size_t k = 0; k < SigList::size; ++k)
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
if((signatureBitsets[k]
|
|
|
|
& std::get<BitsetType>(entities[j]))
|
|
|
|
== signatureBitsets[k])
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-10 04:19:50 +00:00
|
|
|
std::lock_guard<std::mutex> guard(
|
2017-11-15 06:36:04 +00:00
|
|
|
mutexes[k]);
|
|
|
|
multiMatchingEntities[k].push_back(j);
|
2017-11-09 12:10:01 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
}, begin, end);
|
2017-11-09 12:10:01 +00:00
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
threads[i].join();
|
|
|
|
}
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
|
2017-11-09 12:10:01 +00:00
|
|
|
// call functions on matching entities
|
2017-11-15 06:36:04 +00:00
|
|
|
EC::Meta::forEachDoubleTuple(
|
|
|
|
EC::Meta::Morph<SigList, std::tuple<> >{},
|
|
|
|
fTuple,
|
|
|
|
[this, &multiMatchingEntities, &threadCount]
|
|
|
|
(auto sig, auto func, auto index)
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
using SignatureComponents =
|
|
|
|
typename EC::Meta::Matching<
|
|
|
|
decltype(sig), ComponentsList>::type;
|
|
|
|
using Helper =
|
|
|
|
EC::Meta::Morph<
|
|
|
|
SignatureComponents,
|
|
|
|
ForMatchingSignatureHelper<> >;
|
|
|
|
if(threadCount <= 1)
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
for(const auto& id : multiMatchingEntities[index])
|
|
|
|
{
|
|
|
|
Helper::call(id, *this, func);
|
|
|
|
}
|
2017-11-09 12:10:01 +00:00
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
else
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
std::vector<std::thread> threads(threadCount);
|
|
|
|
std::size_t s = multiMatchingEntities[index].size()
|
|
|
|
/ threadCount;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = multiMatchingEntities[index].size();
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread(
|
|
|
|
[this, &multiMatchingEntities, &index, &func]
|
|
|
|
(std::size_t begin, std::size_t end)
|
|
|
|
{
|
|
|
|
for(std::size_t j = begin; j < end;
|
|
|
|
++j)
|
|
|
|
{
|
|
|
|
Helper::call(
|
|
|
|
multiMatchingEntities[index][j],
|
|
|
|
*this,
|
|
|
|
func);
|
|
|
|
}
|
|
|
|
}, begin, end);
|
2017-11-09 12:10:01 +00:00
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
2017-11-09 12:10:01 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
threads[i].join();
|
2017-11-09 12:10:01 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
);
|
2017-11-09 12:10:01 +00:00
|
|
|
}
|
|
|
|
|
2017-11-14 04:11:32 +00:00
|
|
|
/*!
|
|
|
|
\brief Call multiple functions with mulitple signatures on all
|
|
|
|
living entities.
|
|
|
|
|
|
|
|
(Living entities as in entities that have not been marked for
|
|
|
|
deletion.)
|
|
|
|
|
|
|
|
Note that this function requires the tuple of functions to hold
|
|
|
|
pointers to functions, not just functions.
|
|
|
|
|
|
|
|
This function requires the first template parameter to be a
|
|
|
|
EC::Meta::TypeList of signatures. Note that a signature is a
|
|
|
|
EC::Meta::TypeList of components and tags, meaning that SigList
|
|
|
|
is a TypeList of TypeLists.
|
|
|
|
|
|
|
|
The second template parameter can be inferred from the function
|
|
|
|
parameter which should be a tuple of functions. The function
|
|
|
|
at any index in the tuple should match with a signature of the
|
|
|
|
same index in the SigList. Behavior is undefined if there are
|
|
|
|
less functions than signatures.
|
|
|
|
|
|
|
|
See the Unit Test of this function in src/test/ECTest.cpp for
|
|
|
|
usage examples.
|
|
|
|
|
|
|
|
This function was created for the use case where there are many
|
|
|
|
entities in the system which can cause multiple calls to
|
|
|
|
forMatchingSignature to be slow due to the overhead of iterating
|
|
|
|
through the entire list of entities on each invocation.
|
|
|
|
This function instead iterates through all entities once,
|
|
|
|
storing matching entities in a vector of vectors (for each
|
|
|
|
signature and function pair) and then calling functions with
|
|
|
|
the matching list of entities.
|
|
|
|
|
|
|
|
Note that multi-threaded or not, functions will be called in order
|
|
|
|
of signatures. The first function signature pair will be called
|
|
|
|
first, then the second, third, and so on.
|
|
|
|
If this function is called with more than 1 thread specified, then
|
|
|
|
the order of entities called is not guaranteed. Otherwise entities
|
|
|
|
will be called in consecutive order by their ID.
|
|
|
|
*/
|
2017-11-15 06:36:04 +00:00
|
|
|
template <typename SigList, typename FTuple>
|
|
|
|
void forMatchingSignaturesPtr(FTuple fTuple,
|
2017-11-14 04:11:32 +00:00
|
|
|
std::size_t threadCount = 1)
|
|
|
|
{
|
|
|
|
std::vector<std::vector<std::size_t> > multiMatchingEntities(
|
|
|
|
SigList::size);
|
|
|
|
BitsetType signatureBitsets[SigList::size];
|
|
|
|
|
|
|
|
// generate bitsets for each signature
|
2017-11-15 06:36:04 +00:00
|
|
|
EC::Meta::forEachWithIndex<SigList>(
|
|
|
|
[this, &signatureBitsets] (auto signature, const auto index) {
|
|
|
|
signatureBitsets[index] =
|
|
|
|
BitsetType::template generateBitset
|
|
|
|
<decltype(signature)>();
|
2017-11-14 04:11:32 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
// find and store entities matching signatures
|
|
|
|
if(threadCount <= 1)
|
|
|
|
{
|
|
|
|
for(std::size_t eid = 0; eid < currentSize; ++eid)
|
|
|
|
{
|
|
|
|
if(!isAlive(eid))
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < SigList::size; ++i)
|
|
|
|
{
|
|
|
|
if((signatureBitsets[i]
|
|
|
|
& std::get<BitsetType>(entities[eid]))
|
|
|
|
== signatureBitsets[i])
|
|
|
|
{
|
|
|
|
multiMatchingEntities[i].push_back(eid);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
std::vector<std::thread> threads(threadCount);
|
2017-11-15 06:36:04 +00:00
|
|
|
std::mutex mutexes[SigList::size];
|
2017-11-14 04:11:32 +00:00
|
|
|
std::size_t s = currentSize / threadCount;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = currentSize;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread(
|
2017-11-15 06:36:04 +00:00
|
|
|
[this, &mutexes, &multiMatchingEntities, &signatureBitsets]
|
|
|
|
(std::size_t begin, std::size_t end)
|
|
|
|
{
|
|
|
|
for(std::size_t j = begin; j < end; ++j)
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
if(!isAlive(j))
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
for(std::size_t k = 0; k < SigList::size; ++k)
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
if((signatureBitsets[k]
|
|
|
|
& std::get<BitsetType>(entities[j]))
|
|
|
|
== signatureBitsets[k])
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
|
|
|
std::lock_guard<std::mutex> guard(
|
2017-11-15 06:36:04 +00:00
|
|
|
mutexes[k]);
|
|
|
|
multiMatchingEntities[k].push_back(j);
|
2017-11-14 04:11:32 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
}, begin, end);
|
2017-11-14 04:11:32 +00:00
|
|
|
}
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
|
|
|
{
|
|
|
|
threads[i].join();
|
|
|
|
}
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
|
2017-11-14 04:11:32 +00:00
|
|
|
// call functions on matching entities
|
2017-11-15 06:36:04 +00:00
|
|
|
EC::Meta::forEachDoubleTuple(
|
|
|
|
EC::Meta::Morph<SigList, std::tuple<> >{},
|
|
|
|
fTuple,
|
|
|
|
[this, &multiMatchingEntities, &threadCount]
|
|
|
|
(auto sig, auto func, auto index)
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
using SignatureComponents =
|
|
|
|
typename EC::Meta::Matching<
|
|
|
|
decltype(sig), ComponentsList>::type;
|
|
|
|
using Helper =
|
|
|
|
EC::Meta::Morph<
|
|
|
|
SignatureComponents,
|
|
|
|
ForMatchingSignatureHelper<> >;
|
|
|
|
if(threadCount <= 1)
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
for(const auto& id : multiMatchingEntities[index])
|
|
|
|
{
|
|
|
|
Helper::callPtr(id, *this, func);
|
|
|
|
}
|
2017-11-14 04:11:32 +00:00
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
else
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
std::vector<std::thread> threads(threadCount);
|
|
|
|
std::size_t s = multiMatchingEntities[index].size()
|
|
|
|
/ threadCount;
|
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
std::size_t begin = s * i;
|
|
|
|
std::size_t end;
|
|
|
|
if(i == threadCount - 1)
|
|
|
|
{
|
|
|
|
end = multiMatchingEntities[index].size();
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
end = s * (i + 1);
|
|
|
|
}
|
|
|
|
threads[i] = std::thread(
|
|
|
|
[this, &multiMatchingEntities, &index, &func]
|
|
|
|
(std::size_t begin, std::size_t end)
|
|
|
|
{
|
|
|
|
for(std::size_t j = begin; j < end;
|
|
|
|
++j)
|
|
|
|
{
|
|
|
|
Helper::callPtr(
|
|
|
|
multiMatchingEntities[index][j],
|
|
|
|
*this,
|
|
|
|
func);
|
|
|
|
}
|
|
|
|
}, begin, end);
|
2017-11-14 04:11:32 +00:00
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
for(std::size_t i = 0; i < threadCount; ++i)
|
2017-11-14 04:11:32 +00:00
|
|
|
{
|
2017-11-15 06:36:04 +00:00
|
|
|
threads[i].join();
|
2017-11-14 04:11:32 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2017-11-15 06:36:04 +00:00
|
|
|
);
|
2017-11-14 04:11:32 +00:00
|
|
|
}
|
|
|
|
|
2016-09-21 12:01:48 +00:00
|
|
|
/*!
|
|
|
|
\brief Resets the Manager, removing all entities.
|
|
|
|
|
|
|
|
Some data may persist but will be overwritten when new entities
|
|
|
|
are added. Thus, do not depend on data to persist after a call to
|
|
|
|
reset().
|
|
|
|
*/
|
|
|
|
void reset()
|
|
|
|
{
|
|
|
|
clearForMatchingFunctions();
|
|
|
|
|
|
|
|
currentSize = 0;
|
|
|
|
currentCapacity = 0;
|
|
|
|
resize(EC_INIT_ENTITIES_SIZE);
|
|
|
|
}
|
2016-03-04 13:59:43 +00:00
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
#endif
|
|
|
|
|