#ifndef _QEMU_WORK_QUEUE_H
#define _QEMU_WORK_QUEUE_H

#include "qemu/osdep.h"
#include "qemu-common.h"
#include "qemu/queue.h"
#include "qemu/thread.h"
#include "qapi/error.h"

struct work_queue_item;

typedef void (*work_queue_func)(struct work_queue_item */*wq_item*/);

struct work_queue_item
{
    QTAILQ_ENTRY(work_queue_item) entry;

    work_queue_func func;
};

struct work_queue
{
    QemuThread thread;
    QemuMutex mutex;
    QemuCond add_cond;
    QemuCond wait_cond;

    QTAILQ_HEAD(, work_queue_item) items;

    int num_items;

    bool destroying;
};

void work_queue_item_init(struct work_queue_item *wq_item,
                          work_queue_func func);

struct work_queue *work_queue_create(const char *name);

void work_queue_add_item(struct work_queue *wq,
                         struct work_queue_item *wq_item);

void work_queue_wait(struct work_queue *wq);

void work_queue_destroy(struct work_queue *wq);

#define TYPE_WORKQUEUEOBJECT "work_queue"

typedef struct {
    Object base;
    struct work_queue *wq;
} WorkQueueObject;

#define WORKQUEUEOBJECT(obj) \
   OBJECT_CHECK(WorkQueueObject, obj, TYPE_WORKQUEUEOBJECT)

WorkQueueObject *workqueueobject_create(bool *ambiguous);

WorkQueueObject *workqueueobject_find(const char *id);

#endif