newlib-cygwin/winsup/cygwin/threaded_queue.h

68 lines
1.6 KiB
C++
Executable File

/* threaded_queue.h
Copyright 2001 Red Hat Inc.
Written by Robert Collins <rbtcollins@hotmail.com>
This file is part of Cygwin.
This software is a copyrighted work licensed under the terms of the
Cygwin license. Please consult the file "CYGWIN_LICENSE" for
details. */
#ifndef _THREADED_QUEUE_
#define _THREADED_QUEUE_
/* a specific request */
class queue_request
{
public:
class queue_request *next;
virtual void process ();
queue_request();
};
typedef DWORD WINAPI threaded_queue_thread_function (LPVOID);
/* parameters for a request finding and submitting loop */
class queue_process_param
{
public:
bool start (threaded_queue_thread_function *, class threaded_queue *);
void stop ();
bool running;
long int shutdown;
class queue_process_param * next;
class threaded_queue *queue;
queue_process_param (bool ninterruptible);
~queue_process_param ();
bool interruptible;
HANDLE interrupt;
HANDLE hThread;
DWORD tid;
};
/* a queue to allocate requests from n submission loops to x worker threads */
class threaded_queue
{
public:
CRITICAL_SECTION queuelock;
HANDLE event;
bool active;
queue_request * request;
unsigned int initial_workers;
unsigned int running;
void create_workers ();
void cleanup ();
void add (queue_request *);
void process_requests (queue_process_param *, threaded_queue_thread_function *);
threaded_queue () : active (false), request (NULL), initial_workers (1), running (0), process_head (NULL) {};
private:
queue_request *process_head;
};
#endif /* _THREADED_QUEUE_ */