Transmission/transmission
1
0
Fork 0
mirror of https://github.com/transmission/transmission.git synced 2026-02-15 07:26:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: simplify session-thread.h with std::bind_front (#8262)

Browse Source 
* chore: housekeeping

* refactor: simplify `session-thread.h` with `std::bind_front`
This commit is contained in:
Yat Ho
2026-01-29 22:06:23 +08:00
committed by GitHub
parent 34bf2c5b21
commit 7de2aadb41
2 changed files with 10 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
libtransmission/session-thread.cc
View File

@@ -200,7 +200,7 @@ public:
return thread_id_ == std::this_thread::get_id();
}
void queue(std::function<void(void)>&& func) override
void queue(callback_t&& func) override
{
work_queue_mutex_.lock();
work_queue_.emplace_back(std::move(func));
@@ -209,7 +209,7 @@ public:
event_active(work_queue_event_.get(), 0, {});
}
void run(std::function<void(void)>&& func) override
void run(callback_t&& func) override
{
if (am_in_session_thread())
{
@@ -222,8 +222,7 @@ public:
}
private:
using callback = std::function<void(void)>;
using work_queue_t = std::list<callback>;
using work_queue_t = std::list<callback_t>;
void session_thread_func(struct event_base* evbase)
{

20
libtransmission/session-thread.h
View File

@@ -17,6 +17,9 @@ struct event_base;
class tr_session_thread
{
protected:
using callback_t = std::function<void()>;
public:
static void tr_evthread_init();
@@ -27,28 +30,19 @@ public:
[[nodiscard]] virtual bool am_in_session_thread() const noexcept = 0;
virtual void queue(std::function<void(void)>&& func) = 0;
virtual void queue(callback_t&& func) = 0;
virtual void run(std::function<void(void)>&& func) = 0;
virtual void run(callback_t&& func) = 0;
template<typename Func, typename... Args>
void queue(Func&& func, Args&&... args)
{
// TODO(tearfur): Use C++20 P0780R2, GCC 9, clang 9
queue(
std::function<void(void)>{
[func = std::forward<Func>(func), args = std::make_tuple(std::forward<Args>(args)...)]()
{ std::apply(std::move(func), std::move(args)); },
});
queue(callback_t{ std::bind_front(std::forward<Func>(func), std::forward<Args>(args)...) });
}
template<typename Func, typename... Args>
void run(Func&& func, Args&&... args)
{
// TODO(tearfur): Use C++20 P0780R2, GCC 9, clang 9
run(std::function<void(void)>{
[func = std::forward<Func>(func), args = std::make_tuple(std::forward<Args>(args)...)]()
{ std::apply(std::move(func), std::move(args)); },
});
run(callback_t{ std::bind_front(std::forward<Func>(func), std::forward<Args>(args)...) });
}
};