1
0
Fork 0
mirror of https://github.com/juce-framework/JUCE.git synced 2026-01-09 23:34:20 +00:00
JUCE/modules/juce_events/broadcasters/juce_LockingAsyncUpdater.h
2024-04-16 11:39:35 +01:00

125 lines
5.1 KiB
C++

/*
==============================================================================
This file is part of the JUCE framework.
Copyright (c) Raw Material Software Limited
JUCE is an open source framework subject to commercial or open source
licensing.
By downloading, installing, or using the JUCE framework, or combining the
JUCE framework with any other source code, object code, content or any other
copyrightable work, you agree to the terms of the JUCE End User Licence
Agreement, and all incorporated terms including the JUCE Privacy Policy and
the JUCE Website Terms of Service, as applicable, which will bind you. If you
do not agree to the terms of these agreements, we will not license the JUCE
framework to you, and you must discontinue the installation or download
process and cease use of the JUCE framework.
JUCE End User Licence Agreement: https://juce.com/legal/juce-8-licence/
JUCE Privacy Policy: https://juce.com/juce-privacy-policy
JUCE Website Terms of Service: https://juce.com/juce-website-terms-of-service/
Or:
You may also use this code under the terms of the AGPLv3:
https://www.gnu.org/licenses/agpl-3.0.en.html
THE JUCE FRAMEWORK IS PROVIDED "AS IS" WITHOUT ANY WARRANTY, AND ALL
WARRANTIES, WHETHER EXPRESSED OR IMPLIED, INCLUDING WARRANTY OF
MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE, ARE DISCLAIMED.
==============================================================================
*/
namespace juce
{
//==============================================================================
/**
A bit like an AsyncUpdater, but guarantees that after cancelPendingUpdate() returns,
the async function will never be called until triggerAsyncUpdate() is called again.
This is an important guarantee for writing classes with async behaviour that can
still be destroyed safely from a background thread.
Note that all of the member functions of this type have a chance of blocking, so
this class is unsuitable for broadcasting changes from a realtime thread.
@tags{Events}
*/
class JUCE_API LockingAsyncUpdater final
{
public:
//==============================================================================
/** Creates a LockingAsyncUpdater object that will call the provided callback
on the main thread when triggered.
Note that the LockingAsyncUpdater takes an internal mutex before calling
the provided callback. Therefore, in order to avoid deadlocks, you should
(ideally) ensure that no locks are taken inside the callbackToUse. If you
do need to take a lock inside the callback, make sure that you do not
hold the same lock while calling any of the LockingAsyncUpdater member
functions.
*/
explicit LockingAsyncUpdater (std::function<void()> callbackToUse);
/** Move constructor. */
LockingAsyncUpdater (LockingAsyncUpdater&& other) noexcept;
/** Move assignment operator. */
LockingAsyncUpdater& operator= (LockingAsyncUpdater&& other) noexcept;
/** Destructor.
If there are any pending callbacks when the object is deleted, these are lost.
The async callback is guaranteed not to be called again once the destructor has
completed.
*/
~LockingAsyncUpdater();
//==============================================================================
/** Causes the callback to be triggered at a later time.
This method returns quickly, after which a callback to the
handleAsyncUpdate() method will be made by the impl thread as
soon as possible.
If an update callback is already pending but hasn't started yet, calling
this method will have no effect.
It's thread-safe to call this method from any thread, BUT beware of calling
it from a real-time (e.g. audio) thread, because it unconditionally locks
a mutex. This may block, e.g. if this is called from a background thread
while the async callback is in progress on the main thread.
*/
void triggerAsyncUpdate();
/** This will stop any pending updates from happening.
If a callback is already in progress on another thread, this will block until
the callback has finished before returning.
*/
void cancelPendingUpdate() noexcept;
/** If an update has been triggered and is pending, this will invoke it
synchronously.
Use this as a kind of "flush" operation - if an update is pending, the
handleAsyncUpdate() method will be called immediately; if no update is
pending, then nothing will be done.
Because this may invoke the callback, this method must only be called on
the main event thread.
*/
void handleUpdateNowIfNeeded();
/** Returns true if there's an update callback in the pipeline. */
bool isUpdatePending() const noexcept;
private:
class Impl;
ReferenceCountedObjectPtr<Impl> impl;
JUCE_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR (LockingAsyncUpdater)
};
} // namespace juce