mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2024-11-22 23:50:19 +00:00
649d2faeab
We had some inconsistencies before: - Sometimes "The", sometimes "the" - Sometimes trailing ".", sometimes no trailing "." I picked the most common one (lowecase "the", trailing ".") and applied it to all copyright headers. By using the exact same string everywhere we can ensure nothing gets missed during a global search (and replace), and that these inconsistencies are not spread any further (as copyright headers are commonly copied to new files).
58 lines
1.3 KiB
C++
58 lines
1.3 KiB
C++
/*
|
|
* Copyright (c) 2021, the SerenityOS developers.
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#include <Kernel/Process.h>
|
|
#include <Kernel/SpinLock.h>
|
|
#include <Kernel/WaitQueue.h>
|
|
#include <Kernel/WorkQueue.h>
|
|
|
|
namespace Kernel {
|
|
|
|
WorkQueue* g_io_work;
|
|
|
|
void WorkQueue::initialize()
|
|
{
|
|
g_io_work = new WorkQueue("IO WorkQueue");
|
|
}
|
|
|
|
WorkQueue::WorkQueue(const char* name)
|
|
{
|
|
RefPtr<Thread> thread;
|
|
Process::create_kernel_process(thread, name, [this] {
|
|
for (;;) {
|
|
WorkItem* item;
|
|
bool have_more;
|
|
{
|
|
ScopedSpinLock lock(m_lock);
|
|
item = m_items.take_first();
|
|
have_more = !m_items.is_empty();
|
|
}
|
|
if (item) {
|
|
item->function(item->data);
|
|
if (item->free_data)
|
|
item->free_data(item->data);
|
|
delete item;
|
|
|
|
if (have_more)
|
|
continue;
|
|
}
|
|
[[maybe_unused]] auto result = m_wait_queue.wait_on({});
|
|
}
|
|
});
|
|
// If we can't create the thread we're in trouble...
|
|
m_thread = thread.release_nonnull();
|
|
}
|
|
|
|
void WorkQueue::do_queue(WorkItem* item)
|
|
{
|
|
{
|
|
ScopedSpinLock lock(m_lock);
|
|
m_items.append(*item);
|
|
}
|
|
m_wait_queue.wake_one();
|
|
}
|
|
|
|
}
|