lafar6502
lafar6502
/ gist:8105682
Last active
January 26, 2021 06:10
some messy code of a synchronization gateway that allows only a single thread of execution for all passed callbacks. It allows new callbacks to be enqueued while they are being executed by another thread.
This implementation is almost certainly broken because I didn't care if it compiles at all and if all closure stuff is done correctly, but hop…
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| public class ConcurrentGateway | |
| { | |
| private ConcurrentQueue<Action> _workQueue = new ConcurrentQueue<Action>(); | |
| private int _writeLock = 0; | |
| [ThreadStatic] | |
| private static AutoResetEvent _waitEvent = new AutoResetEvent(false); | |
| protected static AutoResetEvent GetThreadWaitEvent() | |
| { |