mirror of
https://github.com/RGBCube/serenity
synced 2025-10-31 15:02:46 +00:00
e9898a6031
The WorkQueue class previously had its own inline storage functionality for function pointers. With the recent changes to the Function class this is no longer necessary.
58 lines
1.2 KiB
C++
58 lines
1.2 KiB
C++
/*
|
|
* Copyright (c) 2021, the SerenityOS developers.
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <AK/IntrusiveList.h>
|
|
#include <Kernel/Forward.h>
|
|
|
|
namespace Kernel {
|
|
|
|
extern WorkQueue* g_io_work;
|
|
|
|
class WorkQueue {
|
|
AK_MAKE_NONCOPYABLE(WorkQueue);
|
|
AK_MAKE_NONMOVABLE(WorkQueue);
|
|
|
|
public:
|
|
static void initialize();
|
|
|
|
WorkQueue(const char*);
|
|
|
|
void queue(void (*function)(void*), void* data = nullptr, void (*free_data)(void*) = nullptr)
|
|
{
|
|
auto* item = new WorkItem; // TODO: use a pool
|
|
item->function = [function, data, free_data] {
|
|
function(data);
|
|
if (free_data)
|
|
free_data(data);
|
|
};
|
|
do_queue(item);
|
|
}
|
|
|
|
template<typename Function>
|
|
void queue(Function function)
|
|
{
|
|
auto* item = new WorkItem; // TODO: use a pool
|
|
item->function = Function(function);
|
|
do_queue(item);
|
|
}
|
|
|
|
private:
|
|
struct WorkItem {
|
|
IntrusiveListNode<WorkItem> m_node;
|
|
Function<void()> function;
|
|
};
|
|
|
|
void do_queue(WorkItem*);
|
|
|
|
RefPtr<Thread> m_thread;
|
|
WaitQueue m_wait_queue;
|
|
IntrusiveList<WorkItem, RawPtr<WorkItem>, &WorkItem::m_node> m_items;
|
|
SpinLock<u8> m_lock;
|
|
};
|
|
|
|
}
|