48 /// </summary>49 /// <param name="state">The state to use.</param>50 /// <param name="component">The <typeparamref name="TComponent"/> to update.</param>51 protected virtual void Update(TState state, ref TComponent component) { }51 protected virtual void Update(TState state, ref TComponent component) { }5253 /// <summary>54 /// Update the given <typeparamref name="TComponent"/> once.98}19 public event ActionIn<Entity> EntityAdded20 {21 add => _set.EntityAdded += value;22 remove => _set.EntityAdded -= value;22 remove => _set.EntityAdded -= value;23 }2425 /// <summary>28 public event ActionIn<Entity> EntityRemoved29 {30 add => _set.EntityRemoved += value;31 remove => _set.EntityRemoved -= value;31 remove => _set.EntityRemoved -= value;32 }3334 #endregion88 /// </summary>89 /// <param name="state">The state to use.</param>90 /// <param name="entity">The <see cref="Entity"/> instance to update.</param>91 protected virtual void Update(T state, in Entity entity) { }91 protected virtual void Update(T state, in Entity entity) { }9293 /// <summary>94 /// Update the given <see cref="Entity"/> instances once.155}2526 private int _referencesCount;2728 public Resource(TResource value)28 public Resource(TResource value)29 {30 Value = value;31 _referencesCount = 0;32 }30 Value = value;31 _referencesCount = 0;32 }3334 public void AddReference() => ++_referencesCount;34 public void AddReference() => ++_referencesCount;3536 public bool RemoveReference() => --_referencesCount == 0;36 public bool RemoveReference() => --_referencesCount == 0;37 }3839 #endregion64 {65 Resource resource;6667 lock (_lockObject)67 lock (_lockObject)68 {69 if (!_resources.TryGetValue(message.ManagedResource.Info, out resource))69 if (!_resources.TryGetValue(message.ManagedResource.Info, out resource))70 {71 resource = new Resource(Load(message.ManagedResource.Info));72 _resources.Add(message.ManagedResource.Info, resource);71 resource = new Resource(Load(message.ManagedResource.Info));72 _resources.Add(message.ManagedResource.Info, resource);73 }7475 resource.AddReference();76 }75 resource.AddReference();76 }7778 OnResourceLoaded(message.Entity, message.ManagedResource.Info, resource.Value);79 }78 OnResourceLoaded(message.Entity, message.ManagedResource.Info, resource.Value);79 }8081 private void On(in ManagedResourceReleaseMessage<ManagedResource<TInfo, TResource>> message)82 {83 lock (_lockObject)83 lock (_lockObject)84 {85 if (_resources.TryGetValue(message.ManagedResource.Info, out Resource resource) && resource.RemoveRefere85 if (_resources.TryGetValue(message.ManagedResource.Info, out Resource resource) && resource.RemoveRefere86 {87 resource.Value?.Dispose();88 _resources.Remove(message.ManagedResource.Info);87 resource.Value?.Dispose();88 _resources.Remove(message.ManagedResource.Info);89 }90 }91 }90 }91 }9293 private void On(in ManagedResourceRequestMessage<ManagedResource<TInfo[], TResource>> message)94 {142 }143144 ComponentPool<ManagedResource<TInfo, TResource>> components = ComponentManager<ManagedResource<TInfo, TResou145 if (components != null)145 if (components != null)146 {147 foreach (Entity entity in world.GetAllEntities().Where(e => components.Has(e.EntityId)))147 foreach (Entity entity in world.GetAllEntities().Where(e => components.Has(e.EntityId)))148 {149 On(new ManagedResourceRequestMessage<ManagedResource<TInfo, TResource>>(entity, components.Get(entit149 On(new ManagedResourceRequestMessage<ManagedResource<TInfo, TResource>>(entity, components.Get(entit150 }151 }152162 /// </summary>163 public void Dispose()164 {165 foreach (Resource resource in _resources.Values)165 foreach (Resource resource in _resources.Values)166 {167 resource.Value?.Dispose();167 resource.Value?.Dispose();168 }169170 _resources.Clear();175}26 IsEnabled = true;27 }2829 /// <summary>30 /// Initialise a new instance of the <see cref="ASystem{T}"/> class.31 /// </summary>32 protected ASystem()33 : this(null)34 { }3536 #endregion3738 #region Methods3940 internal abstract void Update(int index, int maxIndex);4142 /// <summary>43 /// Performs a pre-update treatment.44 /// </summary>45 /// <param name="state">The state to use.</param>46 protected virtual void PreUpdate(T state) { }4748 /// <summary>49 /// Performs a post-update treatment.50 /// </summary>51 /// <param name="state">The state to use.</param>52 protected virtual void PostUpdate(T state) { }5354 #endregion29 #endregion3031 #region Methods3233 internal abstract void Update(int index, int maxIndex);3435 /// <summary>36 /// Performs a pre-update treatment.37 /// </summary>38 /// <param name="state">The state to use.</param>39 protected virtual void PreUpdate(T state) { }4041 /// <summary>42 /// Performs a post-update treatment.43 /// </summary>44 /// <param name="state">The state to use.</param>45 protected virtual void PostUpdate(T state) { }4647 #endregion4849 #region ISystem5051 /// <summary>52 /// Gets or sets whether the current <see cref="ASystem{T}"/> instance should update or not.53 /// </summary>54 public virtual bool IsEnabled { get; set; }5556 #region ISystem5758 /// <summary>59 /// Gets or sets whether the current <see cref="ASystem{T}"/> instance should update or not.60 /// </summary>61 public virtual bool IsEnabled { get; set; }6263 /// <summary>64 /// Updates the system once.65 /// </summary>66 /// <param name="state">The state to use.</param>67 public void Update(T state)68 {69 if (IsEnabled)70 {71 CurrentState = state;7273 PreUpdate(CurrentState);7475 _runner.Update(this);7677 PostUpdate(CurrentState);78 }79 }8081 #endregion56 /// <summary>57 /// Updates the system once.58 /// </summary>59 /// <param name="state">The state to use.</param>60 public void Update(T state)61 {62 if (IsEnabled)63 {64 CurrentState = state;6566 PreUpdate(CurrentState);6768 _runner.Update(this);6970 PostUpdate(CurrentState);71 }72 }7374 #endregion7576 #region IDisposable7778 /// <summary>79 /// Does nothing.80 /// </summary>81 public abstract void Dispose();8283 #region IDisposable8485 /// <summary>86 /// Does nothing.87 /// </summary>88 public abstract void Dispose();8990 #endregion91 }92}83 #endregion84 }85}63}8 [MethodImpl(MethodImplOptions.NoInlining)]9 private static void InnerEnsureLength<T>(ref T[] array, int index, int maxLength)10 {11 int newLength = Math.Max(1, array.Length);11 int newLength = Math.Max(1, array.Length);12 do13 {14 newLength *= 2;14 newLength *= 2;15 }16 while (index >= newLength);17 Array.Resize(ref array, Math.Min(maxLength, newLength));18 }16 while (index >= newLength);17 Array.Resize(ref array, Math.Min(maxLength, newLength));18 }1920 [MethodImpl(MethodImplOptions.AggressiveInlining)]21 public static void Fill<T>(this T[] array, in T value, int start = 0)22 {23 for (int i = start; i < array.Length; ++i)23 for (int i = start; i < array.Length; ++i)24 {25 array[i] = value;25 array[i] = value;26 }27 }27 }2829 [MethodImpl(MethodImplOptions.AggressiveInlining)]30 public static void EnsureLength<T>(ref T[] array, int index, int maxLength = int.MaxValue)31 {32 if (index >= array.Length)32 if (index >= array.Length)33 {34 InnerEnsureLength(ref array, index, maxLength);34 InnerEnsureLength(ref array, index, maxLength);35 }36 }36 }3738 [MethodImpl(MethodImplOptions.AggressiveInlining)]39 public static void EnsureLength<T>(ref T[] array, int index, int maxLength, in T defaultValue)40 {41 if (index >= array.Length)41 if (index >= array.Length)42 {43 int oldLength = array.Length;43 int oldLength = array.Length;4445 InnerEnsureLength(ref array, index, maxLength);46 array.Fill(defaultValue, oldLength);45 InnerEnsureLength(ref array, index, maxLength);46 array.Fill(defaultValue, oldLength);47 }48 }48 }49 }50}27 {28 #region IOperation2930 public void SetMaximumComponentCount(World world, int maxComponentCount) => world.SetMaximumComponentCount<T30 public void SetMaximumComponentCount(World world, int maxComponentCount) => world.SetMaximumComponentCount<T3132 public void SetComponent(in Entity entity, Stream stream, byte[] buffer, byte* bufferP) => entity.Set(Conver32 public void SetComponent(in Entity entity, Stream stream, byte[] buffer, byte* bufferP) => entity.Set(Conver3334 public void SetSameAsComponent(in Entity entity, in Entity reference) => entity.SetSameAs<T>(reference);3573 Dictionary<ushort, IOperation> operations = new Dictionary<ushort, IOperation>();7475 int entryType;76 while ((entryType = stream.ReadByte()) >= 0)76 while ((entryType = stream.ReadByte()) >= 0)77 {78 switch ((EntryType)entryType)78 switch ((EntryType)entryType)79 {80 case EntryType.ComponentType:81 stream.Read(buffer, 0, sizeof(ushort));82 operations.Add(83 *(ushort*)bufferP,84 _operations.GetOrAdd(85 Type.GetType(Converter<string>.Read(stream, buffer, bufferP), true),86 t => (IOperation)Activator.CreateInstance(typeof(Operation<>).MakeGenericTyp87 break;81 stream.Read(buffer, 0, sizeof(ushort));82 operations.Add(83 *(ushort*)bufferP,84 _operations.GetOrAdd(85 Type.GetType(Converter<string>.Read(stream, buffer, bufferP), true),86 t => (IOperation)Activator.CreateInstance(typeof(Operation<>).MakeGenericTyp87 break;8889 case EntryType.MaxComponentCount:90 stream.Read(buffer, 0, sizeof(ushort) + sizeof(int));91 operations[*(ushort*)bufferP].SetMaximumComponentCount(world, *(int*)((ushort*)buffe92 break;90 stream.Read(buffer, 0, sizeof(ushort) + sizeof(int));91 operations[*(ushort*)bufferP].SetMaximumComponentCount(world, *(int*)((ushort*)buffe92 break;9394 case EntryType.Entity:95 currentEntity = world.CreateEntity();97 break;9899 case EntryType.Component:100 stream.Read(buffer, 0, sizeof(ushort));101 operations[*(ushort*)bufferP].SetComponent(currentEntity, stream, buffer, bufferP);102 break;100 stream.Read(buffer, 0, sizeof(ushort));101 operations[*(ushort*)bufferP].SetComponent(currentEntity, stream, buffer, bufferP);102 break;103104 case EntryType.ComponentSameAs:105 stream.Read(buffer, 0, sizeof(ushort) + sizeof(int));272}100}78 public ComponentAddedMessage(int entityId, ComponentEnum components)9 {10 EntityId = entityId;11 Components = components;12 }10 EntityId = entityId;11 Components = components;12 }13 }14}229}78 public ComponentChangedMessage(int entityId, ComponentEnum components)9 {10 EntityId = entityId;11 Components = components;12 }10 EntityId = entityId;11 Components = components;12 }13 }14}19 public bool this[ComponentFlag flag]20 {21 [MethodImpl(MethodImplOptions.AggressiveInlining)]22 get => flag.Index < _bitArray?.Length && (_bitArray[flag.Index] & flag.Bit) != 0;22 get => flag.Index < _bitArray?.Length && (_bitArray[flag.Index] & flag.Bit) != 0;23 [MethodImpl(MethodImplOptions.AggressiveInlining)]24 set25 {26 if ((_bitArray?.Length ?? 0) < flag.Index + 1)26 if ((_bitArray?.Length ?? 0) < flag.Index + 1)27 {28 uint[] newBitArray = new uint[flag.Index + 1];29 _bitArray?.CopyTo(newBitArray, 0);30 _bitArray = newBitArray;28 uint[] newBitArray = new uint[flag.Index + 1];29 _bitArray?.CopyTo(newBitArray, 0);30 _bitArray = newBitArray;31 }3233 if (value)33 if (value)34 {35 _bitArray[flag.Index] |= flag.Bit;36 }35 _bitArray[flag.Index] |= flag.Bit;36 }37 else38 {39 _bitArray[flag.Index] &= ~flag.Bit;39 _bitArray[flag.Index] &= ~flag.Bit;40 }41 }41 }42 }4344 #endregion48 [MethodImpl(MethodImplOptions.AggressiveInlining)]49 public bool Contains(ComponentEnum filter)50 {51 if (filter._bitArray != null)51 if (filter._bitArray != null)52 {53 for (int i = 0; i < filter._bitArray.Length; ++i)53 for (int i = 0; i < filter._bitArray.Length; ++i)54 {55 uint part = filter._bitArray[i];56 if (part != 057 && (i >= _bitArray?.Length || (_bitArray[i] & part) != part))55 uint part = filter._bitArray[i];56 if (part != 057 && (i >= _bitArray?.Length || (_bitArray[i] & part) != part))58 {59 return false;59 return false;60 }61 }62 }6364 return true;64 return true;65 }6667 [MethodImpl(MethodImplOptions.AggressiveInlining)]94 }9596 [MethodImpl(MethodImplOptions.AggressiveInlining)]97 public void Clear() => _bitArray?.Fill(0u);97 public void Clear() => _bitArray.Fill(0u);9899 public override unsafe string ToString()100 {109}2425 private ComponentFlag(int index, uint bit)26 {27 Index = index;28 Bit = bit;29 }27 Index = index;28 Bit = bit;29 }3031 #endregion323435 public static ComponentFlag GetNextFlag()36 {37 lock (_lockObject)37 lock (_lockObject)38 {39 ComponentFlag flag = _lastFlag;40 _lastFlag = _lastFlag.Bit != 0x8000_0000 ? new ComponentFlag(_lastFlag.Index, _lastFlag.Bit << 1) : new 39 ComponentFlag flag = _lastFlag;40 _lastFlag = _lastFlag.Bit != 0x8000_0000 ? new ComponentFlag(_lastFlag.Index, _lastFlag.Bit << 1) : new 4142 return flag;42 return flag;43 }44 }44 }4546 #endregion47 }48}1314 public ComponentLink(int entityId)15 {16 EntityId = entityId;17 ReferenceCount = 1;18 }16 EntityId = entityId;17 ReferenceCount = 1;18 }1920 #endregion21 }22}2021 static ComponentManager()22 {23 _lockObject = new object();23 _lockObject = new object();2425 Flag = ComponentFlag.GetNextFlag();25 Flag = ComponentFlag.GetNextFlag();2627 Pools = EmptyArray<ComponentPool<T>>.Value;27 Pools = EmptyArray<ComponentPool<T>>.Value;2829 Publisher<WorldDisposedMessage>.Subscribe(0, On);30 }29 Publisher<WorldDisposedMessage>.Subscribe(0, On);30 }3132 #endregion333536 private static void On(in WorldDisposedMessage message)37 {38 lock (_lockObject)38 lock (_lockObject)39 {40 if (message.WorldId < Pools.Length)40 if (message.WorldId < Pools.Length)41 {42 Pools[message.WorldId] = null;42 Pools[message.WorldId] = null;43 }44 }45 }44 }45 }4647 #endregion4851 [MethodImpl(MethodImplOptions.NoInlining)]52 private static ComponentPool<T> Add(int worldId, int maxEntityCount, int maxComponentCount)53 {54 lock (_lockObject)54 lock (_lockObject)55 {56 ArrayExtension.EnsureLength(ref Pools, worldId);56 ArrayExtension.EnsureLength(ref Pools, worldId);5758 ref ComponentPool<T> pool = ref Pools[worldId];59 if (pool == null)58 ref ComponentPool<T> pool = ref Pools[worldId];59 if (pool == null)60 {61 pool = new ComponentPool<T>(worldId, maxEntityCount, maxComponentCount);61 pool = new ComponentPool<T>(worldId, maxEntityCount, maxComponentCount);62 }6364 return pool;64 return pool;65 }66 }66 }6768 [MethodImpl(MethodImplOptions.AggressiveInlining)]69 public static ComponentPool<T> Get(int worldId) => worldId < Pools.Length ? Pools[worldId] : null;69 public static ComponentPool<T> Get(int worldId) => worldId < Pools.Length ? Pools[worldId] : null;7071 [MethodImpl(MethodImplOptions.AggressiveInlining)]72 public static ComponentPool<T> GetOrCreate(int worldId, int maxComponentCount) => Get(worldId) ?? Add(worldId, W72 public static ComponentPool<T> GetOrCreate(int worldId, int maxComponentCount) => Get(worldId) ?? Add(worldId, W7374 [MethodImpl(MethodImplOptions.AggressiveInlining)]75 public static ComponentPool<T> GetOrCreate(int worldId) => Get(worldId) ?? Add(worldId, World.Infos[worldId].Max75 public static ComponentPool<T> GetOrCreate(int worldId) => Get(worldId) ?? Add(worldId, World.Infos[worldId].Max7677 #endregion78 }79}2728 #region Properties2930 public int MaxComponentCount { get; }30 public int MaxComponentCount { get; }3132 public bool IsNotEmpty => _lastComponentIndex > -1;333738 static ComponentPool()39 {40 TypeInfo typeInfo = typeof(T).GetTypeInfo();40 TypeInfo typeInfo = typeof(T).GetTypeInfo();4142 _isReferenceType = !typeInfo.IsValueType;43 _isFlagType = typeInfo.IsFlagType();44 _isManagedResourceType = typeInfo.GenericTypeArguments.Length > 0 && typeInfo.GetGenericTypeDefinition() == 45 }42 _isReferenceType = !typeInfo.IsValueType;43 _isFlagType = typeInfo.IsFlagType();44 _isManagedResourceType = typeInfo.GenericTypeArguments.Length > 0 && typeInfo.GetGenericTypeDefinition() == 45 }4647 public ComponentPool(int worldId, int maxEntityCount, int maxComponentCount)47 public ComponentPool(int worldId, int maxEntityCount, int maxComponentCount)48 {49 _worldId = worldId;50 _maxEntityCount = maxEntityCount;51 MaxComponentCount = _isFlagType ? 1 : Math.Min(maxEntityCount, maxComponentCount);49 _worldId = worldId;50 _maxEntityCount = maxEntityCount;51 MaxComponentCount = _isFlagType ? 1 : Math.Min(maxEntityCount, maxComponentCount);5253 _mapping = EmptyArray<int>.Value;54 _links = EmptyArray<ComponentLink>.Value;55 _components = EmptyArray<T>.Value;56 _lastComponentIndex = -1;53 _mapping = EmptyArray<int>.Value;54 _links = EmptyArray<ComponentLink>.Value;55 _components = EmptyArray<T>.Value;56 _lastComponentIndex = -1;5758 Publisher<ComponentTypeReadMessage>.Subscribe(_worldId, On);59 Publisher<EntityDisposedMessage>.Subscribe(_worldId, On);60 Publisher<EntityCopyMessage>.Subscribe(_worldId, On);61 Publisher<ComponentReadMessage>.Subscribe(_worldId, On);58 Publisher<ComponentTypeReadMessage>.Subscribe(_worldId, On);59 Publisher<EntityDisposedMessage>.Subscribe(_worldId, On);60 Publisher<EntityCopyMessage>.Subscribe(_worldId, On);61 Publisher<ComponentReadMessage>.Subscribe(_worldId, On);6263 if (_isManagedResourceType)63 if (_isManagedResourceType)64 {65 Publisher<ManagedResourceReleaseAllMessage>.Subscribe(_worldId, On);66 }67 }67 }6869 #endregion7071 #region Callbacks7273 private void On(in ComponentTypeReadMessage message) => message.Reader.OnRead<T>(MaxComponentCount);73 private void On(in ComponentTypeReadMessage message) => message.Reader.OnRead<T>(MaxComponentCount);7475 private void On(in EntityDisposedMessage message) => Remove(message.EntityId);75 private void On(in EntityDisposedMessage message) => Remove(message.EntityId);7677 private void On(in EntityCopyMessage message)78 {8485 private void On(in ComponentReadMessage message)86 {87 int componentIndex = message.EntityId < _mapping.Length ? _mapping[message.EntityId] : -1;88 if (componentIndex != -1)87 int componentIndex = message.EntityId < _mapping.Length ? _mapping[message.EntityId] : -1;88 if (componentIndex != -1)89 {90 message.Reader.OnRead(ref _components[componentIndex], new Entity(_worldId, _links[componentIndex].Entit90 message.Reader.OnRead(ref _components[componentIndex], new Entity(_worldId, _links[componentIndex].Entit91 }92 }92 }9394 private void On(in ManagedResourceReleaseAllMessage message)95 {110 private void ThrowMaxNumberOfComponentReached() => throw new InvalidOperationException($"Max number of component111112 [MethodImpl(MethodImplOptions.AggressiveInlining)]113 public bool Has(int entityId) => entityId < _mapping.Length && _mapping[entityId] != -1;113 public bool Has(int entityId) => entityId < _mapping.Length && _mapping[entityId] != -1;114115 [MethodImpl(MethodImplOptions.AggressiveInlining)]116 public bool Set(int entityId, in T component)117 {118 ArrayExtension.EnsureLength(ref _mapping, entityId, _maxEntityCount, -1);118 ArrayExtension.EnsureLength(ref _mapping, entityId, _maxEntityCount, -1);119120 ref int componentIndex = ref _mapping[entityId];121 if (componentIndex != -1)120 ref int componentIndex = ref _mapping[entityId];121 if (componentIndex != -1)122 {123 if (_isManagedResourceType)123 if (_isManagedResourceType)124 {125 Publisher.Publish(_worldId, new ManagedResourceReleaseMessage<T>(_components[componentIndex]));125 Publisher.Publish(_worldId, new ManagedResourceReleaseMessage<T>(_components[componentIndex]));126 }127128 _components[componentIndex] = component;128 _components[componentIndex] = component;129130 if (_isManagedResourceType)130 if (_isManagedResourceType)131 {132 Publisher.Publish(_worldId, new ManagedResourceRequestMessage<T>(new Entity(_worldId, entityId), com132 Publisher.Publish(_worldId, new ManagedResourceRequestMessage<T>(new Entity(_worldId, entityId), com133 }134135 return false;135 return false;136 }137138 if (_lastComponentIndex == MaxComponentCount - 1)138 if (_lastComponentIndex == MaxComponentCount - 1)139 {140 if (_isFlagType)141 {145 ThrowMaxNumberOfComponentReached();146 }147148 componentIndex = ++_lastComponentIndex;148 componentIndex = ++_lastComponentIndex;149150 ArrayExtension.EnsureLength(ref _components, _lastComponentIndex, MaxComponentCount);151 ArrayExtension.EnsureLength(ref _links, _lastComponentIndex, MaxComponentCount);150 ArrayExtension.EnsureLength(ref _components, _lastComponentIndex, MaxComponentCount);151 ArrayExtension.EnsureLength(ref _links, _lastComponentIndex, MaxComponentCount);152153 _components[_lastComponentIndex] = component;154 _links[_lastComponentIndex] = new ComponentLink(entityId);153 _components[_lastComponentIndex] = component;154 _links[_lastComponentIndex] = new ComponentLink(entityId);155156 if (_isManagedResourceType)156 if (_isManagedResourceType)157 {158 Publisher.Publish(_worldId, new ManagedResourceRequestMessage<T>(new Entity(_worldId, entityId), compone159 }160161 return true;161 return true;162 }163164 [MethodImpl(MethodImplOptions.AggressiveInlining)]195 [MethodImpl(MethodImplOptions.AggressiveInlining)]196 public bool Remove(int entityId)197 {198 if (entityId >= _mapping.Length)198 if (entityId >= _mapping.Length)199 {200 return false;201 }202203 ref int componentIndex = ref _mapping[entityId];204 if (componentIndex == -1)203 ref int componentIndex = ref _mapping[entityId];204 if (componentIndex == -1)205 {206 return false;206 return false;207 }208209 if (_isManagedResourceType)209 if (_isManagedResourceType)210 {211 Publisher.Publish(_worldId, new ManagedResourceReleaseMessage<T>(_components[componentIndex]));212 }213214 ref ComponentLink link = ref _links[componentIndex];215 if (--link.ReferenceCount == 0)214 ref ComponentLink link = ref _links[componentIndex];215 if (--link.ReferenceCount == 0)216 {217 if (componentIndex != _lastComponentIndex)217 if (componentIndex != _lastComponentIndex)218 {219 ComponentLink lastLink = _links[_lastComponentIndex];220 _links[componentIndex] = lastLink;221 _components[componentIndex] = _components[_lastComponentIndex];222 if (lastLink.ReferenceCount == 1)219 ComponentLink lastLink = _links[_lastComponentIndex];220 _links[componentIndex] = lastLink;221 _components[componentIndex] = _components[_lastComponentIndex];222 if (lastLink.ReferenceCount == 1)223 {224 _mapping[lastLink.EntityId] = componentIndex;225 }224 _mapping[lastLink.EntityId] = componentIndex;225 }226 else227 {228 for (int i = 0; i < _mapping.Length; ++i)235 }236 }237238 if (_isReferenceType)238 if (_isReferenceType)239 {240 _components[_lastComponentIndex] = default;240 _components[_lastComponentIndex] = default;241 }242 --_lastComponentIndex;243 }242 --_lastComponentIndex;243 }244 else if (link.EntityId == entityId)245 {246 int linkIndex = componentIndex;254 }255 }256257 componentIndex = -1;257 componentIndex = -1;258259 return true;259 return true;260 }261262 [MethodImpl(MethodImplOptions.AggressiveInlining)]263 public ref T Get(int entityId) => ref _components[_mapping[entityId]];263 public ref T Get(int entityId) => ref _components[_mapping[entityId]];264265 [MethodImpl(MethodImplOptions.AggressiveInlining)]266 public Span<T> GetAll() => new Span<T>(_components, 0, _lastComponentIndex + 1);270}16}78 public ComponentRemovedMessage(int entityId, ComponentEnum components)9 {10 EntityId = entityId;11 Components = components;12 }10 EntityId = entityId;11 Components = components;12 }13 }14}14}3637 void IComponentTypeReader.OnRead<T>(int maxComponentCount)38 {39 _types.Add(typeof(T), _currentType);39 _types.Add(typeof(T), _currentType);4041 *_bufferP = (byte)EntryType.ComponentType;42 ushort* entryType = (ushort*)(_bufferP + 1);43 *(entryType++) = _currentType;44 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort));45 Converter<string>.Write(typeof(T).AssemblyQualifiedName, _stream, _buffer, _bufferP);41 *_bufferP = (byte)EntryType.ComponentType;42 ushort* entryType = (ushort*)(_bufferP + 1);43 *(entryType++) = _currentType;44 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort));45 Converter<string>.Write(typeof(T).AssemblyQualifiedName, _stream, _buffer, _bufferP);4647 if (maxComponentCount != _maxEntityCount)47 if (maxComponentCount != _maxEntityCount)48 {49 *_bufferP = (byte)EntryType.MaxComponentCount;50 entryType = (ushort*)(_bufferP + 1);51 *(entryType++) = _currentType;52 *(int*)entryType = maxComponentCount;49 *_bufferP = (byte)EntryType.MaxComponentCount;50 entryType = (ushort*)(_bufferP + 1);51 *(entryType++) = _currentType;52 *(int*)entryType = maxComponentCount;5354 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort) + sizeof(int));54 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort) + sizeof(int));55 }5657 ++_currentType;58 }57 ++_currentType;58 }5960 #endregion61 }62}3132 void IComponentTypeReader.OnRead<T>(int maxComponentCount)33 {34 string shortName = typeof(T).Name;34 string shortName = typeof(T).Name;3536 int repeatCount = 1;37 while (_types.ContainsValue(shortName))36 int repeatCount = 1;37 while (_types.ContainsValue(shortName))38 {39 shortName = $"{typeof(T).Name}_{repeatCount++}";39 shortName = $"{typeof(T).Name}_{repeatCount++}";40 }4142 _types.Add(typeof(T), shortName);42 _types.Add(typeof(T), shortName);4344 _writer.WriteLine($"{nameof(EntryType.ComponentType)} {shortName} {typeof(T).FullName}, {typeof(T).GetTypeIn45 if (maxComponentCount != _maxEntityCount)44 _writer.WriteLine($"{nameof(EntryType.ComponentType)} {shortName} {typeof(T).FullName}, {typeof(T).GetTypeIn45 if (maxComponentCount != _maxEntityCount)46 {47 _writer.WriteLine($"{nameof(EntryType.MaxComponentCount)} {shortName} {maxComponentCount}");47 _writer.WriteLine($"{nameof(EntryType.MaxComponentCount)} {shortName} {maxComponentCount}");48 }49 }49 }5051 #endregion52 }53}9596 static Converter()97 {98 _type = typeof(T);99 TypeInfo typeInfo = _type.GetTypeInfo();98 _type = typeof(T);99 TypeInfo typeInfo = _type.GetTypeInfo();100101 if (_type == typeof(string))101 if (_type == typeof(string))102 {103 _writeAction = (Converter.WriteAction<T>)(Delegate)new Converter.WriteAction<string>(StringConverter.Wri104 _readAction = (Converter.ReadAction<T>)(Delegate)new Converter.ReadAction<string>(StringConverter.Read);105 }106 else if (typeInfo.IsArray)106 else if (typeInfo.IsArray)107 {108 Type elementType = typeInfo.GetElementType();109114 {115 try116 {117 if (typeInfo.IsUnmanaged())117 if (typeInfo.IsUnmanaged())118 {119 TypeInfo unmanagedType = typeof(UnmanagedConverter<>).MakeGenericType(_type).GetTypeInfo();119 TypeInfo unmanagedType = typeof(UnmanagedConverter<>).MakeGenericType(_type).GetTypeInfo();120121 _writeAction = (Converter.WriteAction<T>)unmanagedType.GetDeclaredMethod(nameof(UnmanagedConvert122 _readAction = (Converter.ReadAction<T>)unmanagedType.GetDeclaredMethod(nameof(UnmanagedConverter123 }121 _writeAction = (Converter.WriteAction<T>)unmanagedType.GetDeclaredMethod(nameof(UnmanagedConvert122 _readAction = (Converter.ReadAction<T>)unmanagedType.GetDeclaredMethod(nameof(UnmanagedConverter123 }124 else125 {126 DynamicMethod writeMethod = new DynamicMethod($"Write_{nameof(T)}", typeof(void), new[] { _type.175 readGenerator.Emit(OpCodes.Ret);176 _readAction = (Converter.ReadAction<T>)readMethod.CreateDelegate(typeof(Converter.ReadAction<T>)177 }178 }178 }179 catch180 {181 _writeAction = (in T _, Stream __, byte[] ___, byte* ____) => throw new InvalidOperationException($"182 _readAction = (_, __, ___) => throw new InvalidOperationException($"Unable to handle type {_type.Ful183 }184 }185 }185 }186187 #endregion188229230 public static void Write(in T value, Stream stream, byte[] buffer, byte* bufferP)231 {232 if (value == default)232 if (value == default)233 {234 stream.WriteByte(0);235 }236 else if (_type == value.GetType())236 else if (_type == value.GetType())237 {238 stream.WriteByte(1);239 _writeAction(value, stream, buffer, bufferP);240 }238 stream.WriteByte(1);239 _writeAction(value, stream, buffer, bufferP);240 }241 else242 {243 stream.WriteByte(2);249250 public static T Read(Stream stream, byte[] buffer, byte* bufferP)251 {252 switch (stream.ReadByte())252 switch (stream.ReadByte())253 {254 case 0:255 return default;256257 case 1:258 return _readAction(stream, buffer, bufferP);258 return _readAction(stream, buffer, bufferP);259260 default:261 return Converter.GetReadAction<T>(StringConverter.Read(stream, buffer, bufferP))(stream, buffer, buf267}96 private const string _arrayEnd = "]";9798 private static readonly bool _isValueType;99 private static readonly char[] _split = new[] { ' ', '\t' };99 private static readonly char[] _split = new[] { ' ', '\t' };100 private static readonly Dictionary<string, ReadFieldAction> _readFieldActions;101 private static readonly Converter.WriteAction<T> _writeAction;102 private static readonly Converter.ReadAction<T> _readAction;107108 static Converter()109 {110 TypeInfo typeInfo = typeof(T).GetTypeInfo();110 TypeInfo typeInfo = typeof(T).GetTypeInfo();111112 _isValueType = typeInfo.IsValueType;112 _isValueType = typeInfo.IsValueType;113114 _readFieldActions = new Dictionary<string, ReadFieldAction>();114 _readFieldActions = new Dictionary<string, ReadFieldAction>();115116 _writeAction = (in T v, StreamWriter w, int _) => w.WriteLine(v.ToString());116 _writeAction = (in T v, StreamWriter w, int _) => w.WriteLine(v.ToString());117118 #region clr types119 if (typeof(T) == typeof(bool))119 if (typeof(T) == typeof(bool))120 {121 _readAction = Converter.ConvertRead<T>(Converter<bool>.GetReadAction(bool.Parse));122 }123 else if (typeof(T) == typeof(sbyte))123 else if (typeof(T) == typeof(sbyte))124 {125 _readAction = Converter.ConvertRead<T>(Converter<sbyte>.GetReadAction(sbyte.Parse));126 }127 else if (typeof(T) == typeof(byte))127 else if (typeof(T) == typeof(byte))128 {129 _readAction = Converter.ConvertRead<T>(Converter<byte>.GetReadAction(byte.Parse));130 }131 else if (typeof(T) == typeof(short))131 else if (typeof(T) == typeof(short))132 {133 _readAction = Converter.ConvertRead<T>(Converter<short>.GetReadAction(short.Parse));134 }135 else if (typeof(T) == typeof(ushort))135 else if (typeof(T) == typeof(ushort))136 {137 _readAction = Converter.ConvertRead<T>(Converter<ushort>.GetReadAction(ushort.Parse));138 }139 else if (typeof(T) == typeof(int))139 else if (typeof(T) == typeof(int))140 {141 _readAction = Converter.ConvertRead<T>(Converter<int>.GetReadAction(int.Parse));142 }143 else if (typeof(T) == typeof(uint))143 else if (typeof(T) == typeof(uint))144 {145 _readAction = Converter.ConvertRead<T>(Converter<uint>.GetReadAction(uint.Parse));146 }147 else if (typeof(T) == typeof(long))147 else if (typeof(T) == typeof(long))148 {149 _readAction = Converter.ConvertRead<T>(Converter<long>.GetReadAction(long.Parse));150 }151 else if (typeof(T) == typeof(ulong))151 else if (typeof(T) == typeof(ulong))152 {153 _readAction = Converter.ConvertRead<T>(Converter<ulong>.GetReadAction(ulong.Parse));154 }155 else if (typeof(T) == typeof(char))155 else if (typeof(T) == typeof(char))156 {157 _readAction = Converter.ConvertRead<T>(Converter<char>.GetReadAction(CharParse));158 }159 else if (typeof(T) == typeof(decimal))159 else if (typeof(T) == typeof(decimal))160 {161 _readAction = Converter.ConvertRead<T>(Converter<decimal>.GetReadAction(decimal.Parse));162 }163 else if (typeof(T) == typeof(double))163 else if (typeof(T) == typeof(double))164 {165 _readAction = Converter.ConvertRead<T>(Converter<double>.GetReadAction(double.Parse));166 }167 else if (typeof(T) == typeof(float))167 else if (typeof(T) == typeof(float))168 {169 _readAction = Converter.ConvertRead<T>(Converter<float>.GetReadAction(float.Parse));170 }171 else if (typeof(T) == typeof(string))171 else if (typeof(T) == typeof(string))172 {173 _readAction = Converter.ConvertRead<T>(Converter<string>.GetReadAction(s => s));174 }175 else if (typeInfo.IsEnum)175 else if (typeInfo.IsEnum)176 {177 ParameterExpression line = Expression.Parameter(typeof(string));178 ParameterExpression reader = Expression.Parameter(typeof(StreamReader));184185 _readAction = Expression.Lambda<Converter.ReadAction<T>>(Expression.Call(typeof(Converter<T>).GetTypeInf186 }187 else if (typeInfo.IsArray)187 else if (typeInfo.IsArray)188 {189 Type elementType = typeInfo.GetElementType();190198199 bool Parameters_string(MethodInfo methodInfo)200 {201 ParameterInfo[] parameters = methodInfo.GetParameters();201 ParameterInfo[] parameters = methodInfo.GetParameters();202203 return parameters.Length == 1204 && parameters[0].ParameterType == typeof(string);203 return parameters.Length == 1204 && parameters[0].ParameterType == typeof(string);205 }206207 bool Parameters_string_string(MethodInfo methodInfo)208 {209 ParameterInfo[] parameters = methodInfo.GetParameters();209 ParameterInfo[] parameters = methodInfo.GetParameters();210211 return parameters.Length == 2212 && parameters[0].ParameterType == typeof(string)213 && parameters[1].ParameterType == typeof(string);211 return parameters.Length == 2212 && parameters[0].ParameterType == typeof(string)213 && parameters[1].ParameterType == typeof(string);214 }215216 #endregion217218 MethodInfo write = typeof(StreamWriter).GetTypeInfo().GetDeclaredMethods(nameof(StreamWriter.Write)).Fir219 MethodInfo writeLineString = typeof(Converter<T>).GetTypeInfo().GetDeclaredMethod(nameof(StreamWriterWri220 MethodInfo stringConcat = typeof(string).GetTypeInfo().GetDeclaredMethods(nameof(string.Concat)).First(P218 MethodInfo write = typeof(StreamWriter).GetTypeInfo().GetDeclaredMethods(nameof(StreamWriter.Write)).Fir219 MethodInfo writeLineString = typeof(Converter<T>).GetTypeInfo().GetDeclaredMethod(nameof(StreamWriterWri220 MethodInfo stringConcat = typeof(string).GetTypeInfo().GetDeclaredMethods(nameof(string.Concat)).First(P221222 ParameterExpression value = Expression.Parameter(typeof(T).MakeByRefType());223 ParameterExpression writer = Expression.Parameter(typeof(StreamWriter));224 ParameterExpression indentation = Expression.Parameter(typeof(int));222 ParameterExpression value = Expression.Parameter(typeof(T).MakeByRefType());223 ParameterExpression writer = Expression.Parameter(typeof(StreamWriter));224 ParameterExpression indentation = Expression.Parameter(typeof(int));225226 ParameterExpression space = Expression.Variable(typeof(string));227 Expression assignSpace = Expression.Assign(space, Expression.Call(typeof(Converter<T>).GetTypeInfo().Get226 ParameterExpression space = Expression.Variable(typeof(string));227 Expression assignSpace = Expression.Assign(space, Expression.Call(typeof(Converter<T>).GetTypeInfo().Get228229 List<Expression> writeExpressions = new List<Expression>230 {231 Expression.Call(writeLineString, writer,Expression.Constant(_objectBegin)),232 Expression.PreIncrementAssign(indentation),233 assignSpace234 };229 List<Expression> writeExpressions = new List<Expression>230 {231 Expression.Call(writeLineString, writer,Expression.Constant(_objectBegin)),232 Expression.PreIncrementAssign(indentation),233 assignSpace234 };235236 while (typeInfo != null)236 while (typeInfo != null)237 {238 foreach (FieldInfo fieldInfo in typeInfo.DeclaredFields.Where(f => !f.IsStatic))238 foreach (FieldInfo fieldInfo in typeInfo.DeclaredFields.Where(f => !f.IsStatic))239 {240 string name = GetFriendlyName(fieldInfo.Name);241 Expression writeField = Expression.Block(265 _readFieldActions.Add(name.ToUpperInvariant(), (ReadFieldAction)readMethod.CreateDelegate(typeof266 }267268 typeInfo = typeInfo.BaseType?.GetTypeInfo();268 typeInfo = typeInfo.BaseType?.GetTypeInfo();269 }270271 writeExpressions.Add(Expression.PreDecrementAssign(indentation));272 writeExpressions.Add(assignSpace);273 writeExpressions.Add(Expression.Call(writeLineString, writer, Expression.Call(stringConcat, space, Expre271 writeExpressions.Add(Expression.PreDecrementAssign(indentation));272 writeExpressions.Add(assignSpace);273 writeExpressions.Add(Expression.Call(writeLineString, writer, Expression.Call(stringConcat, space, Expre274275 _writeAction = Expression.Lambda<Converter.WriteAction<T>>(Expression.Block(new[] { space }, writeExpres275 _writeAction = Expression.Lambda<Converter.WriteAction<T>>(Expression.Block(new[] { space }, writeExpres276277 _readAction = ReadAnyType;277 _readAction = ReadAnyType;278 }279 }279 }280281 #endregion282306307 private static T ReadAnyType(string line, StreamReader reader)308 {309 while ((string.IsNullOrWhiteSpace(line) || line.Split(_split, StringSplitOptions.RemoveEmptyEntries)[0] != _309 while ((string.IsNullOrWhiteSpace(line) || line.Split(_split, StringSplitOptions.RemoveEmptyEntries)[0] != _310 {311 line = reader.ReadLine();312 }313314 T value = _isValueType ? default : (T)ObjectInitializer.Create(typeof(T));314 T value = _isValueType ? default : (T)ObjectInitializer.Create(typeof(T));315316 while (!reader.EndOfStream)316 while (!reader.EndOfStream)317 {318 line = reader.ReadLine();319 string[] parts = line.Split(_split, 2, StringSplitOptions.RemoveEmptyEntries);320 if (parts.Length > 0)318 line = reader.ReadLine();319 string[] parts = line.Split(_split, 2, StringSplitOptions.RemoveEmptyEntries);320 if (parts.Length > 0)321 {322 if (parts[0] == _objectEnd)322 if (parts[0] == _objectEnd)323 {324 break;325 }330 }331 }332333 return value;333 return value;334 }335336 private static T[] ReadArray(string line, StreamReader reader)364 return Enum.TryParse(entry, out TEnum value) ? value : throw new ArgumentException($"Unable to convert '{ent365 }366367 private static string CreateIndentation(int indentation) => string.Join(string.Empty, Enumerable.Repeat('\t', in367 private static string CreateIndentation(int indentation) => string.Join(string.Empty, Enumerable.Repeat('\t', in368369 private static void StreamWriterWriteLine(StreamWriter writer, string line) => writer.WriteLine(line);369 private static void StreamWriterWriteLine(StreamWriter writer, string line) => writer.WriteLine(line);370371 private static void WriteArray(in T[] values, StreamWriter writer, int indentation)372 {385386 public static void Write(in T value, StreamWriter writer, int indentation)387 {388 if (value == default)388 if (value == default)389 {390 writer.WriteLine("null");391 }392 else if (typeof(T) == value.GetType())392 else if (typeof(T) == value.GetType())393 {394 _writeAction(value, writer, indentation);395 }394 _writeAction(value, writer, indentation);395 }396 else397 {398 Type type = value.GetType();403404 public static T Read(string line, StreamReader reader)405 {406 while (string.IsNullOrWhiteSpace(line) && !reader.EndOfStream)406 while (string.IsNullOrWhiteSpace(line) && !reader.EndOfStream)407 {408 line = reader.ReadLine();409 }410411 if (line?.StartsWith("null") ?? true)411 if (line?.StartsWith("null") ?? true)412 {413 return default;414 }415 else if (line.StartsWith("$type"))415 else if (line.StartsWith("$type"))416 {417 return Converter.GetReadAction<T>(Type.GetType(line.Split(_split, 2)[1], true))(string.Empty, reader);418 }419 else420 {421 return _readAction(line, reader);421 return _readAction(line, reader);422 }423 }424427}9#if NETSTANDARD1_110 public static T[] Value { get; } = new T[0];11#else12 public static T[] Value => Array.Empty<T>();12 public static T[] Value => Array.Empty<T>();13#endif14 }15}2829 internal Entity(int worldId, int entityId)30 {31 WorldId = worldId;32 EntityId = entityId;33 }31 WorldId = worldId;32 EntityId = entityId;33 }3435 #endregion3637 #region Properties3839 [DebuggerBrowsable(DebuggerBrowsableState.Never)]40 private ref ComponentEnum Components => ref World.Infos[WorldId].EntityInfos[EntityId].Components;40 private ref ComponentEnum Components => ref World.Infos[WorldId].EntityInfos[EntityId].Components;4142 /// <summary>43 /// Gets whether the current <see cref="Entity"/> is alive or not.87 /// <exception cref="InvalidOperationException"><see cref="Entity"/> was not created from a <see cref="World"/>.88 public void Enable()89 {90 if (WorldId == 0) Throw("Entity was not created from a World");90 if (WorldId == 0) Throw("Entity was not created from a World");9192 ref ComponentEnum components = ref Components;93 if (!components[World.IsEnabledFlag])92 ref ComponentEnum components = ref Components;93 if (!components[World.IsEnabledFlag])94 {95 components[World.IsEnabledFlag] = true;96 Publisher.Publish(WorldId, new EntityEnabledMessage(EntityId, components));95 components[World.IsEnabledFlag] = true;96 Publisher.Publish(WorldId, new EntityEnabledMessage(EntityId, components));97 }98 }98 }99100 /// <summary>101 /// Disables the current <see cref="Entity"/> so it does not appear in <see cref="EntitySet"/>.119 /// <typeparam name="T">The type of the component.</typeparam>120 /// <returns>true if the <see cref="Entity"/> has a component of type <typeparamref name="T"/> enabled; otherwis121 [MethodImpl(MethodImplOptions.AggressiveInlining)]122 public bool IsEnabled<T>() => WorldId == 0 ? false : Components[ComponentManager<T>.Flag];122 public bool IsEnabled<T>() => WorldId == 0 ? false : Components[ComponentManager<T>.Flag];123124 /// <summary>125 /// Enables the current <see cref="Entity"/> component of type <typeparamref name="T"/> so it can appear in <see169 /// <exception cref="InvalidOperationException">Max number of component of type <typeparamref name="T"/> reached170 public void Set<T>(in T component = default)171 {172 if (WorldId == 0) Throw("Entity was not created from a World");172 if (WorldId == 0) Throw("Entity was not created from a World");173174 ref ComponentEnum components = ref Components;175 if (ComponentManager<T>.GetOrCreate(WorldId).Set(EntityId, component))174 ref ComponentEnum components = ref Components;175 if (ComponentManager<T>.GetOrCreate(WorldId).Set(EntityId, component))176 {177 components[ComponentManager<T>.Flag] = true;178 if (components[World.IsEnabledFlag])177 components[ComponentManager<T>.Flag] = true;178 if (components[World.IsEnabledFlag])179 {180 Publisher.Publish(WorldId, new ComponentAddedMessage<T>(EntityId, components));180 Publisher.Publish(WorldId, new ComponentAddedMessage<T>(EntityId, components));181 }182 }183 else if (components[World.IsEnabledFlag] && components[ComponentManager<T>.Flag])182 }183 else if (components[World.IsEnabledFlag] && components[ComponentManager<T>.Flag])184 {185 Publisher.Publish(WorldId, new ComponentChangedMessage<T>(EntityId, components));185 Publisher.Publish(WorldId, new ComponentChangedMessage<T>(EntityId, components));186 }187 }187 }188189 /// <summary>190 /// Sets the value of the component of type <typeparamref name="T"/> on the current <see cref="Entity"/> to the 222 /// <typeparam name="T">The type of the component.</typeparam>223 public void Remove<T>()224 {225 if (ComponentManager<T>.Get(WorldId)?.Remove(EntityId) ?? false)225 if (ComponentManager<T>.Get(WorldId)?.Remove(EntityId) ?? false)226 {227 ref ComponentEnum components = ref Components;228 components[ComponentManager<T>.Flag] = false;229 if (components[World.IsEnabledFlag])227 ref ComponentEnum components = ref Components;228 components[ComponentManager<T>.Flag] = false;229 if (components[World.IsEnabledFlag])230 {231 Publisher.Publish(WorldId, new ComponentRemovedMessage<T>(EntityId, components));231 Publisher.Publish(WorldId, new ComponentRemovedMessage<T>(EntityId, components));232 }233 }234 }234 }235236 /// <summary>237 /// Returns whether the current <see cref="Entity"/> has a component of type <typeparamref name="T"/>.239 /// <typeparam name="T">The type of the component.</typeparam>240 /// <returns>true if the <see cref="Entity"/> has a component of type <typeparamref name="T"/>; otherwise, false241 [MethodImpl(MethodImplOptions.AggressiveInlining)]242 public bool Has<T>() => WorldId < ComponentManager<T>.Pools.Length && (ComponentManager<T>.Pools[WorldId]?.Has(E242 public bool Has<T>() => WorldId < ComponentManager<T>.Pools.Length && (ComponentManager<T>.Pools[WorldId]?.Has(E243244 /// <summary>245 /// Gets the component of type <typeparamref name="T"/> on the current <see cref="Entity"/>.248 /// <returns>A reference to the component.</returns>249 /// <exception cref="Exception"><see cref="Entity"/> was not created from a <see cref="World"/> or does not have250 [MethodImpl(MethodImplOptions.AggressiveInlining)]251 public ref T Get<T>() => ref ComponentManager<T>.Pools[WorldId].Get(EntityId);251 public ref T Get<T>() => ref ComponentManager<T>.Pools[WorldId].Get(EntityId);252253 /// <summary>254 /// Makes it so when given <see cref="Entity"/> is disposed, current <see cref="Entity"/> will also be disposed.382 /// </summary>383 /// <param name="other">An object to compare with this object.</param>384 /// <returns>true if the current object is equal to the other parameter; otherwise, false.</returns>385 public bool Equals(Entity other) => EntityId == other.EntityId && WorldId == other.WorldId;385 public bool Equals(Entity other) => EntityId == other.EntityId && WorldId == other.WorldId;386387 #endregion388396 /// true if obj and this instance are the same type and represent the same value;397 /// otherwise, false.398 /// </returns>399 public override bool Equals(object obj) => obj is Entity entity && Equals(entity);399 public override bool Equals(object obj) => obj is Entity entity && Equals(entity);400401 /// <summary>402 /// Returns the hash code for this instance.403 /// </summary>404 /// <returns>A 32-bit signed integer that is the hash code for this instance.</returns>405 public override int GetHashCode() => EntityId;405 public override int GetHashCode() => EntityId;406407 /// <summary>408 /// Returns a string representation of this instance.415}31}26 /// <summary>27 /// Gets the maximum capacity the current instance can grow to.28 /// </summary>29 public int MaxCapacity { get; }29 public int MaxCapacity { get; }3031 /// <summary>32 /// Gets current capacity of the current instance.118119 do120 {121 commandOffset = _nextCommandOffset;122 nextCommandOffset = commandOffset + commandSize;123 if (nextCommandOffset > _memory.Length)121 commandOffset = _nextCommandOffset;122 nextCommandOffset = commandOffset + commandSize;123 if (nextCommandOffset > _memory.Length)124 {125 if (nextCommandOffset > MaxCapacity)125 if (nextCommandOffset > MaxCapacity)126 {127 Throw();128 }129130 _lockObject?.EnterWriteLock();130 _lockObject?.EnterWriteLock();131 try132 {133 ArrayExtension.EnsureLength(ref _memory, nextCommandOffset, MaxCapacity);134 }133 ArrayExtension.EnsureLength(ref _memory, nextCommandOffset, MaxCapacity);134 }135 finally136 {137 _lockObject?.ExitWriteLock();138 }137 _lockObject?.ExitWriteLock();138 }139 }140 }141 while (Interlocked.CompareExchange(ref _nextCommandOffset, nextCommandOffset, commandOffset) != commandOffse141 while (Interlocked.CompareExchange(ref _nextCommandOffset, nextCommandOffset, commandOffset) != commandOffse142143 return commandOffset;144 }240}67 public EntityCreatedMessage(int entityId)8 {9 EntityId = entityId;10 }9 EntityId = entityId;10 }11 }12}12}12}12}78 public EntityEnabledMessage(int entityId, ComponentEnum components)9 {10 EntityId = entityId;11 Components = components;12 }10 EntityId = entityId;11 Components = components;12 }13 }14}100}100}100}45 }46 EntityAddedEvent += value;47 }48 remove => EntityAddedEvent -= value;48 remove => EntityAddedEvent -= value;49 }5051 /// <summary>62 /// </summary>63 public int Count64 {65 get;66 private set;65 get;66 private set;67 }6869 #endregion100 {101 if (_filter(world.Info.EntityInfos[i].Components))102 {103 Add(i);103 Add(i);104 }105 }106 }113 [MethodImpl(MethodImplOptions.AggressiveInlining)]114 private void Add(int entityId)115 {116 ArrayExtension.EnsureLength(ref _mapping, entityId, _maxEntityCount, -1);116 ArrayExtension.EnsureLength(ref _mapping, entityId, _maxEntityCount, -1);117118 ref int index = ref _mapping[entityId];119 if (index == -1)118 ref int index = ref _mapping[entityId];119 if (index == -1)120 {121 index = Count++;121 index = Count++;122123 ArrayExtension.EnsureLength(ref _entities, index, _maxEntityCount);123 ArrayExtension.EnsureLength(ref _entities, index, _maxEntityCount);124125 _entities[index] = new Entity(_worldId, entityId);126 EntityAddedEvent?.Invoke(_entities[index]);125 _entities[index] = new Entity(_worldId, entityId);126 EntityAddedEvent?.Invoke(_entities[index]);127 }128 }129130 [MethodImpl(MethodImplOptions.AggressiveInlining)]131 private void Remove(int entityId)132 {133 if (entityId < _mapping.Length)133 if (entityId < _mapping.Length)134 {135 ref int index = ref _mapping[entityId];136 if (index != -1)135 ref int index = ref _mapping[entityId];136 if (index != -1)137 {138 Entity entity = _entities[index];139 --Count;138 Entity entity = _entities[index];139 --Count;140141 if (index != Count)141 if (index != Count)142 {143 _entities[index] = _entities[Count];144 _mapping[_entities[Count].EntityId] = index;145 }146147 index = -1;147 index = -1;148149 EntityRemoved?.Invoke(entity);149 EntityRemoved?.Invoke(entity);150 }151 }152 }155156 internal void CheckedAdd(in EntityEnabledMessage message)157 {158 if (_filter(message.Components))158 if (_filter(message.Components))159 {160 Add(message.EntityId);160 Add(message.EntityId);161 }162 }162 }163164 internal void CheckedAdd<T>(in ComponentAddedMessage<T> message)165 {166 if (_filter(message.Components))166 if (_filter(message.Components))167 {168 Add(message.EntityId);168 Add(message.EntityId);169 }170 }170 }171172 internal void CheckedAdd<T>(in ComponentChangedMessage<T> message)173 {187188 internal void Remove(in EntityDisposingMessage message) => Remove(message.EntityId);189190 internal void Remove(in EntityDisabledMessage message) => Remove(message.EntityId);190 internal void Remove(in EntityDisabledMessage message) => Remove(message.EntityId);191192 internal void Remove<T>(in ComponentRemovedMessage<T> message) => Remove(message.EntityId);192 internal void Remove<T>(in ComponentRemovedMessage<T> message) => Remove(message.EntityId);193194 internal void Remove<T>(in ComponentAddedMessage<T> message) => Remove(message.EntityId);195210 }211212 [MethodImpl(MethodImplOptions.AggressiveInlining)]213 internal ReadOnlySpan<Entity> GetEntities(int start, int length) => new ReadOnlySpan<Entity>(_entities, start, l213 internal ReadOnlySpan<Entity> GetEntities(int start, int length) => new ReadOnlySpan<Entity>(_entities, start, l214215 /// <summary>216 /// Gets the <see cref="Entity"/> contained in the current <see cref="EntitySet"/>.217 /// </summary>218 /// <returns>A <see cref="ReadOnlySpan{T}"/> of the <see cref="Entity"/> contained in the current <see cref="Ent219 [MethodImpl(MethodImplOptions.AggressiveInlining)]220 public ReadOnlySpan<Entity> GetEntities() => GetEntities(0, Count);220 public ReadOnlySpan<Entity> GetEntities() => GetEntities(0, Count);221222 /// <summary>223 /// Clears current instance of its entities if it was created with some reactive filter (<seealso cref="EntitySe247}495}103}64}35 {36 if (withoutEitherFilters is null)37 {38 return c => c.Contains(withFilter);38 return c => c.Contains(withFilter);39 }4041 if (withoutEitherFilters.Count == 1)129}7778 void IComponentReader.OnRead<T>(ref T component, in Entity componentOwner)79 {80 if (!_types.TryGetValue(typeof(T), out ushort _))80 if (!_types.TryGetValue(typeof(T), out ushort _))81 {82 _types.Add(typeof(T), _currentType);82 _types.Add(typeof(T), _currentType);8384 *_bufferP = (byte)EntryType.ComponentType;85 ushort* entryType = (ushort*)(_bufferP + 1);86 *(entryType++) = _currentType;87 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort));88 Converter<string>.Write(typeof(T).AssemblyQualifiedName, _stream, _buffer, _bufferP);84 *_bufferP = (byte)EntryType.ComponentType;85 ushort* entryType = (ushort*)(_bufferP + 1);86 *(entryType++) = _currentType;87 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort));88 Converter<string>.Write(typeof(T).AssemblyQualifiedName, _stream, _buffer, _bufferP);8990 ++_currentType;90 ++_currentType;91 }9293 Tuple<Entity, Type> componentKey = Tuple.Create(componentOwner, typeof(T));94 if (_components.TryGetValue(componentKey, out int key))93 Tuple<Entity, Type> componentKey = Tuple.Create(componentOwner, typeof(T));94 if (_components.TryGetValue(componentKey, out int key))95 {96 *_bufferP = (byte)(_currentEntity.IsEnabled<T>() ? EntryType.ComponentSameAs : EntryType.DisabledCompone97 ushort* typeId = (ushort*)(_bufferP + 1);102 }103 else104 {105 _components.Add(componentKey, _entityCount);106 *_bufferP = (byte)(_currentEntity.IsEnabled<T>() ? EntryType.Component : EntryType.DisabledComponent);107 *(ushort*)(_bufferP + 1) = _types[typeof(T)];105 _components.Add(componentKey, _entityCount);106 *_bufferP = (byte)(_currentEntity.IsEnabled<T>() ? EntryType.Component : EntryType.DisabledComponent);107 *(ushort*)(_bufferP + 1) = _types[typeof(T)];108109 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort));109 _stream.Write(_buffer, 0, sizeof(byte) + sizeof(ushort));110111 Converter<T>.Write(component, _stream, _buffer, _bufferP);111 Converter<T>.Write(component, _stream, _buffer, _bufferP);112 }113 }113 }114115 #endregion116 }117}6667 void IComponentReader.OnRead<T>(ref T component, in Entity componentOwner)68 {69 if (!_types.TryGetValue(typeof(T), out _))69 if (!_types.TryGetValue(typeof(T), out _))70 {71 string typeName = typeof(T).Name;71 string typeName = typeof(T).Name;7273 int repeatCount = 1;74 while (_types.ContainsValue(typeName))73 int repeatCount = 1;74 while (_types.ContainsValue(typeName))75 {76 typeName = $"{typeof(T).Name}_{repeatCount++}";76 typeName = $"{typeof(T).Name}_{repeatCount++}";77 }7879 _types.Add(typeof(T), typeName);79 _types.Add(typeof(T), typeName);8081 _writer.WriteLine($"{nameof(EntryType.ComponentType)} {typeName} {typeof(T).FullName}, {typeof(T).GetTyp81 _writer.WriteLine($"{nameof(EntryType.ComponentType)} {typeName} {typeof(T).FullName}, {typeof(T).GetTyp82 }8384 Tuple<Entity, Type> componentKey = Tuple.Create(componentOwner, typeof(T));85 if (_components.TryGetValue(componentKey, out int key))84 Tuple<Entity, Type> componentKey = Tuple.Create(componentOwner, typeof(T));85 if (_components.TryGetValue(componentKey, out int key))86 {87 string entry = _currentEntity.IsEnabled<T>() ? nameof(EntryType.ComponentSameAs) : nameof(EntryType.Disa88 _writer.WriteLine($"{entry} {_types[typeof(T)]} {key}");89 }90 else91 {92 _components.Add(componentKey, _entityCount);93 string entry = _currentEntity.IsEnabled<T>() ? nameof(EntryType.Component) : nameof(EntryType.DisabledCo94 _writer.Write($"{entry} {_types[typeof(T)]} ");95 Converter<T>.Write(component, _writer, 0);92 _components.Add(componentKey, _entityCount);93 string entry = _currentEntity.IsEnabled<T>() ? nameof(EntryType.Component) : nameof(EntryType.DisabledCo94 _writer.Write($"{entry} {_types[typeof(T)]} ");95 Converter<T>.Write(component, _writer, 0);96 }97 }97 }9899 #endregion100 }101}1819 #region Initialisation2021 public DisposableGroup(IEnumerable<IDisposable> disposables)21 public DisposableGroup(IEnumerable<IDisposable> disposables)22 {23 _disposables = GetDisposables(disposables).ToArray();24 }23 _disposables = GetDisposables(disposables).ToArray();24 }2526 #endregion272930 private IEnumerable<IDisposable> GetDisposables(IEnumerable<IDisposable> disposables)31 {32 foreach (IDisposable disposable in disposables)32 foreach (IDisposable disposable in disposables)33 {34 if (disposable is DisposableGroup group)34 if (disposable is DisposableGroup group)35 {36 foreach (IDisposable child in group._disposables)37 {40 }41 else42 {43 yield return disposable;43 yield return disposable;44 }45 }46 }46 }4748 #endregion496667 #region Methods6869 public static IDisposable Merge(this IEnumerable<IDisposable> disposables) => new DisposableGroup(disposables ??69 public static IDisposable Merge(this IEnumerable<IDisposable> disposables) => new DisposableGroup(disposables ??7071 #endregion72 }73}2829 private static IDisposable Subscribe(IPublisher publisher, Type type, object target)30 {31 List<IDisposable> subscriptions = new List<IDisposable>();31 List<IDisposable> subscriptions = new List<IDisposable>();3233 try34 {35 while (type != null)35 while (type != null)36 {37 foreach (MethodInfo method in type.GetTypeInfo().DeclaredMethods38 .Where(m => m.GetCustomAttribute<SubscribeAttribute>(false) != null && (m.IsStatic || target != 37 foreach (MethodInfo method in type.GetTypeInfo().DeclaredMethods38 .Where(m => m.GetCustomAttribute<SubscribeAttribute>(false) != null && (m.IsStatic || target != 39 {40 ParameterInfo[] parameters = method.GetParameters();40 ParameterInfo[] parameters = method.GetParameters();4142 if (parameters.Length != 143 || !parameters[0].ParameterType.IsByRef44 || method.ReturnType != typeof(void))42 if (parameters.Length != 143 || !parameters[0].ParameterType.IsByRef44 || method.ReturnType != typeof(void))45 {46 throw new NotSupportedException($"Can't apply {nameof(SubscribeAttribute)} to \"{method.Name47 }4849 Type argType = parameters[0].ParameterType.GetElementType();50 subscriptions.Add((IDisposable)_subscribeMethod.MakeGenericMethod(argType).Invoke(51 publisher,52 new object[]53 {54 method.IsStatic55 ? method.CreateDelegate(typeof(ActionIn<>).MakeGenericType(argType))56 : method.CreateDelegate(typeof(ActionIn<>).MakeGenericType(argType), target)57 }));49 Type argType = parameters[0].ParameterType.GetElementType();50 subscriptions.Add((IDisposable)_subscribeMethod.MakeGenericMethod(argType).Invoke(51 publisher,52 new object[]53 {54 method.IsStatic55 ? method.CreateDelegate(typeof(ActionIn<>).MakeGenericType(argType))56 : method.CreateDelegate(typeof(ActionIn<>).MakeGenericType(argType), target)57 }));58 }5960 type = type.GetTypeInfo().BaseType;60 type = type.GetTypeInfo().BaseType;61 }62 }62 }63 catch64 {65 foreach (IDisposable disposable in subscriptions)70 throw;71 }7273 return subscriptions.Count > 1 ? subscriptions.Merge() : subscriptions.FirstOrDefault();73 return subscriptions.Count > 1 ? subscriptions.Merge() : subscriptions.FirstOrDefault();74 }7576 /// <summary>111 public static IDisposable Subscribe<T>(this IPublisher publisher, T target)112 where T : class113 {114 return Subscribe(115 publisher ?? throw new ArgumentNullException(nameof(publisher)),116 (target ?? throw new ArgumentNullException(nameof(target))).GetType(),117 target);114 return Subscribe(115 publisher ?? throw new ArgumentNullException(nameof(publisher)),116 (target ?? throw new ArgumentNullException(nameof(target))).GetType(),117 target);118 }119120 #endregion122}| Method | Cyclomatic complexity | NPath complexity | Sequence coverage | Branch coverage |
|---|---|---|---|---|
| Serialize(...) | 1 | 0 | 0% | 100% |
| Serialize(...) | 1 | 0 | 100% | 100% |
14 /// <param name="serializer">The <see cref="ISerializer"/> instance to use.</param>15 /// <param name="stream">The <see cref="Stream"/> in which the data will be saved.</param>16 /// <param name="entities">The <see cref="Entity"/> instances to save.</param>17 public static void Serialize(this ISerializer serializer, Stream stream, params Entity[] entities) => serializer17 public static void Serialize(this ISerializer serializer, Stream stream, params Entity[] entities) => serializer18 }1920 /// <summary>54}1516 #region Properties1718 public int LastInt => _lastInt;18 public int LastInt => _lastInt;1920 #endregion2122 #region Initialisation2324 public IntDispenser(int startInt)24 public IntDispenser(int startInt)25 {26 _freeInts = new ConcurrentStack<int>();26 _freeInts = new ConcurrentStack<int>();2728 _lastInt = startInt;29 }28 _lastInt = startInt;29 }3031 #endregion323435 public int GetFreeInt()36 {37 if (!_freeInts.TryPop(out int freeInt))37 if (!_freeInts.TryPop(out int freeInt))38 {39 freeInt = Interlocked.Increment(ref _lastInt);39 freeInt = Interlocked.Increment(ref _lastInt);40 }4142 return freeInt;42 return freeInt;43 }4445 public void ReleaseInt(int releasedInt) => _freeInts.Push(releasedInt);45 public void ReleaseInt(int releasedInt) => _freeInts.Push(releasedInt);4647 #endregion48 }49}23}67 public ManagedResourceReleaseMessage(T managedResource)8 {9 ManagedResource = managedResource;10 }9 ManagedResource = managedResource;10 }11 }12}1011 public ManagedResourceRequestMessage(in Entity entity, T managedResource)12 {13 Entity = entity;14 ManagedResource = managedResource;15 }13 Entity = entity;14 ManagedResource = managedResource;15 }16 }17}21 /// <param name="info">The info used to identify the resource.</param>22 public ManagedResource(TInfo info)23 {24 Info = info;25 }24 Info = info;25 }26 }27}87}8 internal static class Publisher9 {10 [MethodImpl(MethodImplOptions.AggressiveInlining)]11 public static void Publish<T>(int worldId, in T message) => Publisher<T>.Publish(worldId, message);11 public static void Publish<T>(int worldId, in T message) => Publisher<T>.Publish(worldId, message);12 }1314 internal static class Publisher<T>117}2829 public Subscription(int worldId, ActionIn<T> action)30 {31 _worldId = worldId;32 _action = action;33 }31 _worldId = worldId;32 _action = action;33 }3435 #endregion366162 static Publisher()63 {64 _lockObject = new object();64 _lockObject = new object();6566 Actions = new ActionIn<T>[2];66 Actions = new ActionIn<T>[2];6768 if (typeof(T) != typeof(WorldDisposedMessage))68 if (typeof(T) != typeof(WorldDisposedMessage))69 {70 Publisher<WorldDisposedMessage>.Subscribe(0, On);70 Publisher<WorldDisposedMessage>.Subscribe(0, On);71 }72 }72 }7374 #endregion757778 private static void On(in WorldDisposedMessage message)79 {80 lock (_lockObject)80 lock (_lockObject)81 {82 if (message.WorldId < Actions.Length)82 if (message.WorldId < Actions.Length)83 {84 Actions[message.WorldId] = null;84 Actions[message.WorldId] = null;85 }86 }87 }86 }87 }8889 #endregion9093 [MethodImpl(MethodImplOptions.AggressiveInlining)]94 public static IDisposable Subscribe(int worldId, ActionIn<T> action)95 {96 lock (_lockObject)96 lock (_lockObject)97 {98 ArrayExtension.EnsureLength(ref Actions, worldId);98 ArrayExtension.EnsureLength(ref Actions, worldId);99100 Actions[worldId] += action;101 }100 Actions[worldId] += action;101 }102103 return new Subscription(worldId, action);103 return new Subscription(worldId, action);104 }105106 [MethodImpl(MethodImplOptions.AggressiveInlining)]107 public static void Publish(int worldId, in T message)108 {109 if (worldId < Actions.Length)109 if (worldId < Actions.Length)110 {111 Actions[worldId]?.Invoke(message);111 Actions[worldId]?.Invoke(message);112 }113 }113 }114115 #endregion116 }117}70}910 public static void Write(in string value, Stream stream, byte[] buffer, byte* bufferP)11 {12 int* lengthP = (int*)bufferP;13 *lengthP++ = value.Length;14 char* valueP = (char*)lengthP;12 int* lengthP = (int*)bufferP;13 *lengthP++ = value.Length;14 char* valueP = (char*)lengthP;1516 int count = sizeof(int);16 int count = sizeof(int);1718 foreach (char c in value)18 foreach (char c in value)19 {20 if (count + sizeof(char) > buffer.Length)20 if (count + sizeof(char) > buffer.Length)21 {22 stream.Write(buffer, 0, count);23 valueP = (char*)bufferP;24 count = 0;25 }2627 *valueP++ = c;28 count += sizeof(char);27 *valueP++ = c;28 count += sizeof(char);29 }3031 stream.Write(buffer, 0, count);32 }31 stream.Write(buffer, 0, count);32 }3334 public static string Read(Stream stream, byte[] buffer, byte* bufferP)35 {36 string value = null;36 string value = null;3738 if (stream.Read(buffer, 0, sizeof(int)) == sizeof(int))38 if (stream.Read(buffer, 0, sizeof(int)) == sizeof(int))39 {40 int totalLength = *(int*)bufferP * sizeof(char);40 int totalLength = *(int*)bufferP * sizeof(char);4142 while (totalLength > 0)42 while (totalLength > 0)43 {44 int length = stream.Read(buffer, 0, Math.Min(buffer.Length, totalLength));44 int length = stream.Read(buffer, 0, Math.Min(buffer.Length, totalLength));4546 if (length <= 0)46 if (length <= 0)47 {48 throw new EndOfStreamException($"Could not deserialize type {typeof(string).FullName}");49 }5051 totalLength -= length;52 value += new string((char*)bufferP, 0, length / sizeof(char));51 totalLength -= length;52 value += new string((char*)bufferP, 0, length / sizeof(char));53 }54 }5556 return value;56 return value;57 }5859 #endregion61}| Method | Cyclomatic complexity | NPath complexity | Sequence coverage | Branch coverage |
|---|---|---|---|---|
| .cctor() | 1 | 0 | 100% | 100% |
| .ctor(...) | 6 | 0 | 100% | 83.33% |
| Update(...) | 2 | 0 | 100% | 100% |
| Update(...) | 4 | 0 | 100% | 100% |
| Dispose() | 4 | 0 | 100% | 50% |
| .cctor() | 1 | 0 | 100% | 100% |
| .ctor(...) | 6 | 0 | 100% | 83.33% |
| Update(...) | 2 | 0 | 100% | 100% |
| Update(...) | 4 | 0 | 100% | 100% |
| Dispose() | 4 | 0 | 100% | 50% |
89namespace DefaultEcs.System10{11 /// <summary>12 /// Represents an helper object used to update a system in parallel.13 /// </summary>14 /// <typeparam name="T">The type of the object used as state to update the system.</typeparam>15 public sealed class SystemRunner<T> : IDisposable16 {17 #region Fields1819 internal static readonly SystemRunner<T> Default = new SystemRunner<T>(1);11 //public interface ISystemRunner<T> : IDisposable12 //{13 // void Update(ASystem<T> system);14 //}1516 //public interface IRunnableSystem<T> : ISystem<T>17 //{18 // void Update(int index, int maxIndex);19 //}2021 private readonly CancellationTokenSource _disposeHandle;22 private readonly WorkerBarrier _barrier;23 private readonly Task[] _tasks;2425 private ASystem<T> _currentSystem;2627 #endregion21 /// <summary>22 /// Represents an helper object used to update a system in parallel.23 /// </summary>24 /// <typeparam name="T">The type of the object used as state to update the system.</typeparam>25 public sealed class SystemRunner<T> : IDisposable26 {27 #region Fields2829 #region Initialisation29 internal static readonly SystemRunner<T> Default = new SystemRunner<T>(1);3031 /// <summary>32 /// Initialises a new instance of the <see cref="SystemRunner{T}"/> class.33 /// </summary>34 /// <param name="degreeOfParallelism">The number of <see cref="Task"/> instances used to update a system in para35 /// <exception cref="ArgumentException"><paramref name="degreeOfParallelism"/> cannot be inferior to one.</excep36 public SystemRunner(int degreeOfParallelism)37 {38 IEnumerable<int> indices = degreeOfParallelism >= 1 ? Enumerable.Range(0, degreeOfParallelism - 1) : throw n3940 _disposeHandle = new CancellationTokenSource();41 _tasks = indices.Select(index => new Task(Update, index, TaskCreationOptions.LongRunning)).ToArray();42 _barrier = degreeOfParallelism > 1 ? new WorkerBarrier(_tasks.Length) : null;4344 foreach (Task task in _tasks)45 {46 task.Start(TaskScheduler.Default);47 }48 }31 private readonly CancellationTokenSource _disposeHandle;32 private readonly WorkerBarrier _barrier;33 private readonly Task[] _tasks;3435 private ASystem<T> _currentSystem;3637 #endregion3839 #region Initialisation4041 /// <summary>42 /// Initialises a new instance of the <see cref="SystemRunner{T}"/> class.43 /// </summary>44 /// <param name="degreeOfParallelism">The number of <see cref="Task"/> instances used to update a system in para45 /// <exception cref="ArgumentException"><paramref name="degreeOfParallelism"/> cannot be inferior to one.</excep46 public SystemRunner(int degreeOfParallelism)47 {48 IEnumerable<int> indices = degreeOfParallelism >= 1 ? Enumerable.Range(0, degreeOfParallelism - 1) : throw n4950 #endregion5152 #region Methods50 _disposeHandle = new CancellationTokenSource();51 _tasks = indices.Select(index => new Task(Update, index, TaskCreationOptions.LongRunning)).ToArray();52 _barrier = degreeOfParallelism > 1 ? new WorkerBarrier(_tasks.Length) : null;5354 private void Update(object state)55 {56 int index = (int)state;5758 goto Start;54 foreach (Task task in _tasks)55 {56 task.Start(TaskScheduler.Default);57 }58 }5960 Work:61 Volatile.Read(ref _currentSystem).Update(index, _tasks.Length);6263 _barrier.Signal();6465 Start:66 _barrier.Start();60 #endregion6162 #region Methods6364 private void Update(object state)65 {66 int index = (int)state;6768 if (!_disposeHandle.IsCancellationRequested)69 {70 goto Work;71 }72 }7374 [MethodImpl(MethodImplOptions.AggressiveInlining)]75 internal void Update(ASystem<T> system)76 {77 Volatile.Write(ref _currentSystem, system);7879 _barrier?.StartWorkers();8081 system.Update(_tasks.Length, _tasks.Length);8283 _barrier?.WaitForWorkers();84 }8586 #endregion8788 #region IDisposable8990 /// <summary>91 /// Releases all the resources used by the current <see cref="SystemRunner{T}"/> instance.92 /// </summary>93 public void Dispose()94 {95 _disposeHandle.Cancel();9697 _barrier?.StartWorkers();9899 Task.WaitAll(_tasks);100101 _barrier?.Dispose();102 _disposeHandle.Dispose();103 }104105 #endregion106 }107}68 goto Start;6970 Work:71 Volatile.Read(ref _currentSystem).Update(index, _tasks.Length);7273 _barrier.Signal();7475 Start:76 _barrier.Start();7778 if (!_disposeHandle.IsCancellationRequested)79 {80 goto Work;81 }82 }8384 [MethodImpl(MethodImplOptions.AggressiveInlining)]85 internal void Update(ASystem<T> system)86 {87 Volatile.Write(ref _currentSystem, system);8889 _barrier?.StartWorkers();9091 system.Update(_tasks.Length, _tasks.Length);9293 _barrier?.WaitForWorkers();94 }9596 #endregion9798 #region IDisposable99100 /// <summary>101 /// Releases all the resources used by the current <see cref="SystemRunner{T}"/> instance.102 /// </summary>103 public void Dispose()104 {105 _disposeHandle.Cancel();106107 _barrier?.StartWorkers();108109 Task.WaitAll(_tasks);110111 _barrier?.Dispose();112 _disposeHandle.Dispose();113 }114115 #endregion116 }117}30 {31 #region IOperation3233 public void SetMaximumComponentCount(World world, int maxComponentCount) => world.SetMaximumComponentCount<T33 public void SetMaximumComponentCount(World world, int maxComponentCount) => world.SetMaximumComponentCount<T3435 public void SetComponent(in Entity entity, string line, StreamReader reader)36 {37 try38 {39 entity.Set(Converter<T>.Read(line, reader));40 }39 entity.Set(Converter<T>.Read(line, reader));40 }41 catch (Exception exception)42 {43 throw new ArgumentException("Error while parsing", exception);44 }45 }45 }4647 public void SetSameAsComponent(in Entity entity, in Entity reference) => entity.SetSameAs<T>(reference);4886 Entity currentEntity = default;87 Dictionary<string, IOperation> operations = new Dictionary<string, IOperation>();8889 while (!reader.EndOfStream)89 while (!reader.EndOfStream)90 {91 string[] lineParts = reader.ReadLine()?.Split(_split, 2, StringSplitOptions.RemoveEmptyEntries);91 string[] lineParts = reader.ReadLine()?.Split(_split, 2, StringSplitOptions.RemoveEmptyEntries);9293 if (lineParts?.Length > 0)93 if (lineParts?.Length > 0)94 {95 string entry = lineParts[0];96 if (nameof(EntryType.Entity).Equals(entry))95 string entry = lineParts[0];96 if (nameof(EntryType.Entity).Equals(entry))97 {98 if (world == null)99 {106 entities.Add(lineParts[1], currentEntity);107 }108 }109 else if (nameof(EntryType.DisabledEntity).Equals(entry))109 else if (nameof(EntryType.DisabledEntity).Equals(entry))110 {111 if (world == null)112 {119 entities.Add(lineParts[1], currentEntity);120 }121 }122 else if (lineParts.Length > 1)122 else if (lineParts.Length > 1)123 {124 switch (entry)125 {141 break;142143 case nameof(EntryType.ComponentType):144 string[] componentTypeEntry = lineParts[1].Split(_split, 2, StringSplitOptions.R145 Type type = Type.GetType(componentTypeEntry[1], false) ?? throw new ArgumentExce144 string[] componentTypeEntry = lineParts[1].Split(_split, 2, StringSplitOptions.R145 Type type = Type.GetType(componentTypeEntry[1], false) ?? throw new ArgumentExce146147 operations.Add(148 componentTypeEntry[0],149 _operations.GetOrAdd(150 type,151 t => (IOperation)Activator.CreateInstance(typeof(Operation<>).MakeGeneri152 break;147 operations.Add(148 componentTypeEntry[0],149 _operations.GetOrAdd(150 type,151 t => (IOperation)Activator.CreateInstance(typeof(Operation<>).MakeGeneri152 break;153154 case nameof(EntryType.MaxComponentCount):155 if (!isNewWorld)155 if (!isNewWorld)156 {157 throw new ArgumentException("Encoutered MaxComponentCount line");158 }159 string[] maxComponentCountEntry = lineParts[1].Split(_split, StringSplitOptions.160 if (maxComponentCountEntry.Length < 2)159 string[] maxComponentCountEntry = lineParts[1].Split(_split, StringSplitOptions.160 if (maxComponentCountEntry.Length < 2)161 {162 throw new ArgumentException($"Unable to get {nameof(EntryType.MaxComponentCo163 }164 if (!operations.TryGetValue(maxComponentCountEntry[0], out IOperation operation)164 if (!operations.TryGetValue(maxComponentCountEntry[0], out IOperation operation)165 {166 throw new ArgumentException($"Unknown component type used '{maxComponentCoun167 }168 if (!int.TryParse(maxComponentCountEntry[1], NumberStyles.Any, CultureInfo.Invar168 if (!int.TryParse(maxComponentCountEntry[1], NumberStyles.Any, CultureInfo.Invar169 {170 throw new ArgumentException($"Unable to convert '{maxComponentCountEntry[1]}171 }172173 if (world == null)173 if (world == null)174 {175 world = new World();176 }177178 operation.SetMaximumComponentCount(world, maxComponentCount);179 break;178 operation.SetMaximumComponentCount(world, maxComponentCount);179 break;180181 case nameof(EntryType.Component):182 if (currentEntity.Equals(default))182 if (currentEntity.Equals(default))183 {184 throw new ArgumentException("Encountered a component before creation of an E185 }186 string[] componentEntry = lineParts[1].Split(_split, 2, StringSplitOptions.Remov187 if (componentEntry.Length < 1)186 string[] componentEntry = lineParts[1].Split(_split, 2, StringSplitOptions.Remov187 if (componentEntry.Length < 1)188 {189 throw new ArgumentException($"Unable to get component type information from 190 }191 if (!operations.TryGetValue(componentEntry[0].TrimEnd(':', '='), out operation))191 if (!operations.TryGetValue(componentEntry[0].TrimEnd(':', '='), out operation))192 {193 throw new ArgumentException($"Unknown component type used '{componentEntry[0194 }195196 operation.SetComponent(currentEntity, componentEntry.Length > 1 ? componentEntry197 break;196 operation.SetComponent(currentEntity, componentEntry.Length > 1 ? componentEntry197 break;198199 case nameof(EntryType.ComponentSameAs):200 if (currentEntity.Equals(default))418}6{7 internal static class TypeExtension8 {9 public static bool IsFlagType(this TypeInfo typeInfo) => typeInfo.IsValueType && !typeInfo.IsEnum && !typeInfo.I9 public static bool IsFlagType(this TypeInfo typeInfo) => typeInfo.IsValueType && !typeInfo.IsEnum && !typeInfo.I1011 public static bool IsUnmanaged(this TypeInfo typeInfo)12 {13 return typeInfo.IsEnum || (typeInfo.IsValueType && (typeInfo.IsPrimitive || typeInfo.DeclaredFields.Where(f 13 return typeInfo.IsEnum || (typeInfo.IsValueType && (typeInfo.IsPrimitive || typeInfo.DeclaredFields.Where(f 14 }1516 public static bool IsUnmanaged(this Type type) => type.GetTypeInfo().IsUnmanaged();18}21}1011 public static void Write(in T value, Stream stream, byte[] buffer, byte* bufferP)12 {13 if (sizeof(T) <= buffer.Length)13 if (sizeof(T) <= buffer.Length)14 {15 *(T*)bufferP = value;15 *(T*)bufferP = value;1617 stream.Write(buffer, 0, sizeof(T));18 }17 stream.Write(buffer, 0, sizeof(T));18 }19 else20 {21 int count = 0;4041 public static T Read(Stream stream, byte[] buffer, byte* bufferP)42 {43 if (sizeof(T) <= buffer.Length)43 if (sizeof(T) <= buffer.Length)44 {45 if (stream.Read(buffer, 0, sizeof(T)) == sizeof(T))45 if (stream.Read(buffer, 0, sizeof(T)) == sizeof(T))46 {47 return *(T*)bufferP;47 return *(T*)bufferP;48 }49 else50 {85}229}229}229}229}229}229}229}229}4142 #region Properties4344 internal int LastEntityId => _entityIdDispenser.LastInt;44 internal int LastEntityId => _entityIdDispenser.LastInt;4546 /// <summary>47 /// Gets the maximum number of <see cref="Entity"/> this <see cref="World"/> can create.48 /// </summary>49 public int MaxEntityCount => Info.MaxEntityCount;49 public int MaxEntityCount => Info.MaxEntityCount;5051 #endregion5268 /// </summary>69 /// <param name="maxEntityCount">The maximum number of <see cref="Entity"/> that can exist in this <see cref="Wo70 /// <exception cref="ArgumentException"><paramref name="maxEntityCount"/> cannot be negative.</exception>71 public World(int maxEntityCount)71 public World(int maxEntityCount)72 {73 if (maxEntityCount < 0)73 if (maxEntityCount < 0)74 {75 throw new ArgumentException("Argument cannot be negative", nameof(maxEntityCount));75 throw new ArgumentException("Argument cannot be negative", nameof(maxEntityCount));76 }7778 _entityIdDispenser = new IntDispenser(-1);79 WorldId = _worldIdDispenser.GetFreeInt();78 _entityIdDispenser = new IntDispenser(-1);79 WorldId = _worldIdDispenser.GetFreeInt();8081 Info = new WorldInfo(maxEntityCount);81 Info = new WorldInfo(maxEntityCount);8283 lock (_lockObject)83 lock (_lockObject)84 {85 ArrayExtension.EnsureLength(ref Infos, WorldId);85 ArrayExtension.EnsureLength(ref Infos, WorldId);8687 Infos[WorldId] = Info;88 }87 Infos[WorldId] = Info;88 }8990 this.Subscribe(this);91 }90 this.Subscribe(this);91 }9293 /// <summary>94 /// Initializes a new instance of the <see cref="World"/> class.105 [Subscribe]106 private void On(in EntityDisposingMessage message)107 {108 Info.EntityInfos[message.EntityId].Components.Clear();109 EntityDisposed?.Invoke(new Entity(WorldId, message.EntityId));110 }108 EntityDisposed?.Invoke(new Entity(WorldId, message.EntityId));109 Info.EntityInfos[message.EntityId].Components.Clear();110 }111112 [Subscribe]113 private void On(in EntityDisposedMessage message)161 /// <exception cref="InvalidOperationException">Max number of <see cref="Entity"/> reached.</exception>162 public Entity CreateEntity()163 {164 int entityId = _entityIdDispenser.GetFreeInt();164 int entityId = _entityIdDispenser.GetFreeInt();165166 if (entityId >= MaxEntityCount)166 if (entityId >= MaxEntityCount)167 {168 throw new InvalidOperationException("Max number of Entity reached");169 }170171 ArrayExtension.EnsureLength(ref Info.EntityInfos, entityId, MaxEntityCount);171 ArrayExtension.EnsureLength(ref Info.EntityInfos, entityId, MaxEntityCount);172173 Info.EntityInfos[entityId].Components[IsAliveFlag] = true;174 Info.EntityInfos[entityId].Components[IsEnabledFlag] = true;175 Publish(new EntityCreatedMessage(entityId));173 Info.EntityInfos[entityId].Components[IsAliveFlag] = true;174 Info.EntityInfos[entityId].Components[IsEnabledFlag] = true;175 Publish(new EntityCreatedMessage(entityId));176177 return new Entity(WorldId, entityId);177 return new Entity(WorldId, entityId);178 }179180 /// <summary>187 /// <exception cref="ArgumentException"><paramref name="maxComponentCount"/> cannot be negative.</exception>188 public bool SetMaximumComponentCount<T>(int maxComponentCount)189 {190 if (maxComponentCount < 0)190 if (maxComponentCount < 0)191 {192 throw new ArgumentException("Argument cannot be negative", nameof(maxComponentCount));193 }194195 return ComponentManager<T>.GetOrCreate(WorldId, maxComponentCount).MaxComponentCount == maxComponentCount;195 return ComponentManager<T>.GetOrCreate(WorldId, maxComponentCount).MaxComponentCount == maxComponentCount;196 }197198 /// <summary>224 /// <returns>All the <see cref="Entity"/> of the current <see cref="World"/>.</returns>225 public IEnumerable<Entity> GetAllEntities()226 {227 for (int i = 0; i <= Math.Min(Info.EntityInfos.Length, LastEntityId); ++i)227 for (int i = 0; i <= Math.Min(Info.EntityInfos.Length, LastEntityId); ++i)228 {229 if (Info.EntityInfos[i].Components[IsAliveFlag])229 if (Info.EntityInfos[i].Components[IsAliveFlag])230 {231 yield return new Entity(WorldId, i);231 yield return new Entity(WorldId, i);232 }233 }234 }234 }235236 /// <summary>237 /// Calls on <paramref name="reader"/> with all the maximum number of component of the current <see cref="World"251 /// <param name="action">The delegate to be called back.</param>252 /// <returns>An <see cref="IDisposable"/> object used to unsubscribe.</returns>253 [MethodImpl(MethodImplOptions.AggressiveInlining)]254 public IDisposable Subscribe<T>(ActionIn<T> action) => Publisher<T>.Subscribe(WorldId, action);254 public IDisposable Subscribe<T>(ActionIn<T> action) => Publisher<T>.Subscribe(WorldId, action);255256 /// <summary>257 /// Publishes a <typeparamref name="T"/> object.259 /// <typeparam name="T">The type of the object to publish.</typeparam>260 /// <param name="message">The object to publish.</param>261 [MethodImpl(MethodImplOptions.AggressiveInlining)]262 public void Publish<T>(in T message) => Publisher<T>.Publish(WorldId, message);262 public void Publish<T>(in T message) => Publisher<T>.Publish(WorldId, message);263264 #endregion265271 /// </summary>272 public void Dispose()273 {274 lock (_lockObject)274 lock (_lockObject)275 {276 Infos[WorldId] = null;277 }276 Infos[WorldId] = null;277 }278279 Publish(new ManagedResourceReleaseAllMessage());280 Publisher.Publish(0, new WorldDisposedMessage(WorldId));281 _worldIdDispenser.ReleaseInt(WorldId);279 Publish(new ManagedResourceReleaseAllMessage());280 Publisher.Publish(0, new WorldDisposedMessage(WorldId));281 _worldIdDispenser.ReleaseInt(WorldId);282283 GC.SuppressFinalize(this);284 }283 GC.SuppressFinalize(this);284 }285286 #endregion287298}67 public WorldDisposedMessage(int worldId)8 {9 WorldId = worldId;10 }9 WorldId = worldId;10 }11 }12}89 public EntityInfo[] EntityInfos;1011 public WorldInfo(int maxEntityCount)11 public WorldInfo(int maxEntityCount)12 {13 MaxEntityCount = maxEntityCount;13 MaxEntityCount = maxEntityCount;1415 EntityInfos = EmptyArray<EntityInfo>.Value;16 }15 EntityInfos = EmptyArray<EntityInfo>.Value;16 }17 }18}