Add DelayedCall and integrate it into navigator and histogram
- Rename `delayedconnection.h` to `delayed.h` - Align `delayed_helper::apply()` with `std::apply()`
This commit is contained in:
Flössie
240
rtgui/delayed.h
Normal file
240
rtgui/delayed.h
Normal file
@@ -0,0 +1,240 @@
|
||||
/*
|
||||
* This file is part of RawTherapee.
|
||||
*
|
||||
* Copyright (C) 2020 Flössie <floessie.mail@gmail.com>
|
||||
*
|
||||
* RawTherapee is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* RawTherapee is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with RawTherapee. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <cstddef>
|
||||
#include <functional>
|
||||
#include <tuple>
|
||||
|
||||
#include <glibmm/main.h>
|
||||
#include <glibmm/signalproxy.h>
|
||||
|
||||
#include "../rtengine/noncopyable.h"
|
||||
|
||||
namespace delayed_helper
|
||||
{
|
||||
|
||||
// C++14
|
||||
|
||||
// See https://gist.github.com/ntessore/dc17769676fb3c6daa1f
|
||||
template<std::size_t... Is>
|
||||
struct index_sequence
|
||||
{
|
||||
};
|
||||
|
||||
template<std::size_t N, std::size_t... Is>
|
||||
struct make_index_sequence :
|
||||
make_index_sequence<N-1, N-1, Is...>
|
||||
{
|
||||
};
|
||||
|
||||
template<std::size_t... Is>
|
||||
struct make_index_sequence<0, Is...> :
|
||||
index_sequence<Is...>
|
||||
{
|
||||
};
|
||||
|
||||
// C++17
|
||||
|
||||
// See https://aherrmann.github.io/programming/2016/02/28/unpacking-tuples-in-cpp14/
|
||||
template<typename F, typename T, size_t... Is>
|
||||
constexpr void apply_impl(F f, T t, index_sequence<Is...>)
|
||||
{
|
||||
f(std::get<Is>(t)...);
|
||||
}
|
||||
|
||||
template <typename T, typename F>
|
||||
constexpr void apply(F f, T t)
|
||||
{
|
||||
apply_impl(f, t, make_index_sequence<std::tuple_size<T>{}>{});
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
template<typename... Ts>
|
||||
class DelayedCall final :
|
||||
public rtengine::NonCopyable
|
||||
{
|
||||
public:
|
||||
DelayedCall(std::function<void (Ts...)> _function, unsigned int _min_delay_ms, unsigned int _max_delay_ms = 0) :
|
||||
function(_function),
|
||||
min_delay_ms(_min_delay_ms),
|
||||
max_delay_ms(_max_delay_ms)
|
||||
{
|
||||
}
|
||||
|
||||
DelayedCall(unsigned int _min_delay_ms, unsigned int _max_delay_ms = 0) :
|
||||
DelayedCall({}, _min_delay_ms, _max_delay_ms)
|
||||
{
|
||||
}
|
||||
|
||||
void setFunction(std::function<void (Ts...)> function)
|
||||
{
|
||||
this->function = function;
|
||||
}
|
||||
|
||||
void operator ()(Ts... ts)
|
||||
{
|
||||
if (!function) {
|
||||
return;
|
||||
}
|
||||
|
||||
if (!min_delay_ms) {
|
||||
function(ts...);
|
||||
return;
|
||||
}
|
||||
|
||||
params = std::make_tuple(ts...);
|
||||
|
||||
min_timeout.disconnect();
|
||||
min_timeout = Glib::signal_timeout().connect(sigc::mem_fun(*this, &DelayedCall::onMinTimeout), min_delay_ms);
|
||||
|
||||
if (max_delay_ms && !max_timeout.connected()) {
|
||||
max_timeout = Glib::signal_timeout().connect(sigc::mem_fun(*this, &DelayedCall::onMaxTimeout), max_delay_ms);
|
||||
}
|
||||
}
|
||||
|
||||
void cancel()
|
||||
{
|
||||
min_timeout.disconnect();
|
||||
max_timeout.disconnect();
|
||||
}
|
||||
|
||||
private:
|
||||
bool onMinTimeout()
|
||||
{
|
||||
max_timeout.disconnect();
|
||||
if (function) {
|
||||
delayed_helper::apply(function, params);
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
bool onMaxTimeout()
|
||||
{
|
||||
min_timeout.disconnect();
|
||||
if (function) {
|
||||
delayed_helper::apply(function, params);
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
std::function<void (Ts...)> function;
|
||||
|
||||
unsigned int min_delay_ms;
|
||||
unsigned int max_delay_ms;
|
||||
|
||||
sigc::connection min_timeout;
|
||||
sigc::connection max_timeout;
|
||||
|
||||
std::tuple<Ts...> params;
|
||||
};
|
||||
|
||||
template<typename... Ts>
|
||||
class DelayedConnection final :
|
||||
public rtengine::NonCopyable
|
||||
{
|
||||
public:
|
||||
DelayedConnection(unsigned int _min_delay_ms, unsigned int _max_delay_ms = 0) :
|
||||
min_delay_ms(_min_delay_ms),
|
||||
max_delay_ms(_max_delay_ms)
|
||||
{
|
||||
}
|
||||
|
||||
void connect(Glib::SignalProxy<void, Ts...> signal, const sigc::slot<void, Ts...>& slot, const sigc::slot<void, Ts...>& immediate_slot = {})
|
||||
{
|
||||
this->slot = slot;
|
||||
this->immediate_slot = immediate_slot;
|
||||
this->signal = signal.connect(sigc::mem_fun(*this, &DelayedConnection::onSignal));
|
||||
}
|
||||
|
||||
void block(bool value = true)
|
||||
{
|
||||
signal.block(value);
|
||||
}
|
||||
|
||||
void unblock()
|
||||
{
|
||||
signal.unblock();
|
||||
}
|
||||
|
||||
void cancel()
|
||||
{
|
||||
min_timeout.disconnect();
|
||||
max_timeout.disconnect();
|
||||
}
|
||||
|
||||
void setDelay(unsigned int min_delay_ms, unsigned int max_delay_ms = 0)
|
||||
{
|
||||
this->min_delay_ms = min_delay_ms;
|
||||
this->max_delay_ms = max_delay_ms;
|
||||
|
||||
min_timeout.disconnect();
|
||||
max_timeout.disconnect();
|
||||
}
|
||||
|
||||
private:
|
||||
void onSignal(Ts... ts)
|
||||
{
|
||||
if (immediate_slot) {
|
||||
immediate_slot(ts...);
|
||||
}
|
||||
|
||||
if (!min_delay_ms) {
|
||||
slot(ts...);
|
||||
return;
|
||||
}
|
||||
|
||||
params = std::make_tuple(ts...);
|
||||
|
||||
min_timeout.disconnect();
|
||||
min_timeout = Glib::signal_timeout().connect(sigc::mem_fun(*this, &DelayedConnection::onMinTimeout), min_delay_ms);
|
||||
|
||||
if (max_delay_ms && !max_timeout.connected()) {
|
||||
max_timeout = Glib::signal_timeout().connect(sigc::mem_fun(*this, &DelayedConnection::onMaxTimeout), max_delay_ms);
|
||||
}
|
||||
}
|
||||
|
||||
bool onMinTimeout()
|
||||
{
|
||||
max_timeout.disconnect();
|
||||
delayed_helper::apply(slot, params);
|
||||
return false;
|
||||
}
|
||||
|
||||
bool onMaxTimeout()
|
||||
{
|
||||
min_timeout.disconnect();
|
||||
delayed_helper::apply(slot, params);
|
||||
return false;
|
||||
}
|
||||
|
||||
unsigned int min_delay_ms;
|
||||
unsigned int max_delay_ms;
|
||||
|
||||
sigc::connection signal;
|
||||
sigc::connection min_timeout;
|
||||
sigc::connection max_timeout;
|
||||
|
||||
sigc::slot<void, Ts...> slot;
|
||||
sigc::slot<void, Ts...> immediate_slot;
|
||||
|
||||
std::tuple<Ts...> params;
|
||||
};
|
||||
Reference in New Issue
Block a user