AlicizaX/DragonECS-ClassicThreads
1
0
Fork 0
mirror of https://github.com/DCFApixels/DragonECS-ClassicThreads.git synced 2025-09-17 19:24:37 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

disallow nested parallel iterations

Browse Source
This commit is contained in:
Mikhail 2023-06-12 12:52:45 +08:00
parent 9d7e2b9003
commit e895d65b21
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/ThreadRunner.cs
View File

@ -13,6 +13,8 @@ namespace DCFApixels.DragonECS
private static int[] _entities = new int[64]; private static int[] _entities = new int[64];
private static List<Exception> _catchedExceptions; private static List<Exception> _catchedExceptions;
private static bool _isRunning = false;
private static void ThreadProc(object obj) private static void ThreadProc(object obj)
{ {
int i = (int)obj; int i = (int)obj;
@ -57,6 +59,11 @@ namespace DCFApixels.DragonECS
public static void Run(ThreadWorkerHandler worker, EcsReadonlyGroup entities, int minSpanSize) public static void Run(ThreadWorkerHandler worker, EcsReadonlyGroup entities, int minSpanSize)
{ {
#if (DEBUG && !DISABLE_DEBUG) || ENABLE_DRAGONECS_ASSERT_CHEKS
if (_isRunning)
throw new InvalidOperationException("It is forbidden to start a parallel iteration before the last one is finished.");
#endif
_isRunning = true;
_worker = worker; _worker = worker;
int entitiesCount = entities.Bake(ref _entities); int entitiesCount = entities.Bake(ref _entities);
@ -96,6 +103,7 @@ namespace DCFApixels.DragonECS
_threads[i].doneWork.WaitOne(); _threads[i].doneWork.WaitOne();
} }
_isRunning = false;
_worker = _nullWorker; _worker = _nullWorker;
if(_catchedExceptions != null) if(_catchedExceptions != null)
{ {