/ doc / DocFrag / ARCCore.StreamProcessor.OutsideLocalReceiver / Attribute / LongDescription

LongDescription

Edit keys at this level only

= Remember thread-safety regarding use of this method.0x000D0x000A0x000D0x000APossible implementions on outside could be:0x000D0x000A0x000D0x000A1) Approach suitable for a processor, running in a continous loop:0x000D0x000A0x000D0x000A   var queue = new System.Collections.Concurrent.ConcurrentQueue0x003Cstring0x003E()0x003B0x000D0x000A   myStreamProcessorInstance.OutsideLocalReceiver = s =0x003E queue.Enqueue(s)0x003B0x000D0x000A0x000D0x000AYou can then pick up from the queue inside your continous processing loop in a thread-safe manner, for instance like this:0x000D0x000A0x000D0x000A   var dataStorage = new PRich()0x003B0x000D0x000A   while (true) 0x007B // Your continous processing loop0x000D0x000A      DoTask1(dataStorage)0x003B  // Task1 may freely access dataStorage (within calling thread)0x000D0x000A      DoTask2(dataStorage)0x003B  // Task2 may freely access dataStorage (within calling thread)0x000D0x000A      while (queue.TryDequeue(out var s)) PropertyStreamLine.ParseAndStore(dataStorage, s)0x003B0x000D0x000A   0x007D0x000D0x000A0x000D0x000A0x000D0x000A2) Approach suitable for an API with incoming requests occuring on multiple threads:0x000D0x000A(simplified code)0x000D0x000A0x000D0x000A    var lock = new System.Threading.ReaderWriterLockSlim()0x003B0x000D0x000A   var dataStorage = new PRich()0x003B0x000D0x000A   myStreamProcessorInstance.OutsideLocalReceiver = s =0x003E 0x007B0x000D0x000A      try 0x007B0x000D0x000A         lock.EnterWriteLock()0x003B0x000D0x000A         PropertyStreamLine.ParseAndStore(_storage, s)0x003B0x000D0x000A      0x007D finally 0x007B0x000D0x000A         lock.ExitWriteLock()0x003B0x000D0x000A      0x007D0x000D0x000A   0x007D0x003B0x000D0x000A0x000D0x000AYou must also remember to acquire the corresponding lock (lock.EnterReadLock or lock.EnterWriteLock) when processing API methods, for instance like this:0x000D0x000A   public APIResponse ServeAPIMethod(APIRequest request) 0x007B0x000D0x000A       try 0x007B0x000D0x000A           lock.EnterReadLock()0x003B0x000D0x000A           return dataStorage.Query(request)0x003B0x000D0x000A       0x007D finally 0x007B0x000D0x000A           lock.ExitReadLock()0x003B0x000D0x000A       0x007D0x000D0x000A   0x007D0x000D0x000A0x000D0x000A

Edit keys at all sub levels.
NOTE: Edits are always additive. Use 'Invalid' in order to delete keys.

Generated 2025-07-06 06:13:00.758 UTC