33 jassert (readerThreads.
size() == 0);
34 jassert (numWriters == 0);
41 readWaitEvent.
wait (100);
50 for (
auto& readerThread : readerThreads)
52 if (readerThread.threadID == threadId)
59 if (numWriters + numWaitingWriters == 0
60 || (threadId == writerThreadId && numWriters > 0))
62 readerThreads.add ({ threadId, 1 });
74 for (
int i = 0; i < readerThreads.
size(); ++i)
78 if (readerThread.threadID == threadId)
80 if (--(readerThread.count) == 0)
101 while (! tryEnterWriteInternal (threadId))
105 writeWaitEvent.
wait (100);
117 bool ReadWriteLock::tryEnterWriteInternal (
Thread::ThreadID threadId)
const noexcept
119 if (readerThreads.
size() + numWriters == 0
120 || threadId == writerThreadId
121 || (readerThreads.
size() == 1 && readerThreads.
getReference (0).threadID == threadId))
123 writerThreadId = threadId;
138 if (--numWriters == 0)
void exitWrite() const noexcept
void ensureStorageAllocated(int minNumElements)
bool tryEnterRead() const noexcept
bool tryEnterWrite() const noexcept
static ThreadID JUCE_CALLTYPE getCurrentThreadId()
void enter() const noexcept
void exit() const noexcept
void enterRead() const noexcept
bool wait(int timeOutMilliseconds=-1) const
int size() const noexcept
void enterWrite() const noexcept
~ReadWriteLock() noexcept
ElementType & getReference(int index) noexcept
void remove(int indexToRemove)
void exitRead() const noexcept