threading.h

#pragma once
#include "compact.h"

#define WIN32_LEAN_AND_MEAN
#include <windows.h>

#define WAIT_FOR_THREADS(threads) { \
	HANDLE events[2];\
	events[0] = m_threads[0].m_doneEvent;\
	events[1] = m_threads[1].m_doneEvent;\
	WaitForMultipleObjects(2, &events[0], true, INFINITE);\
}

struct ThreadData
{
	volatile HANDLE m_thread;
	volatile HANDLE m_startEvent; 
	volatile HANDLE m_doneEvent;
	CompressClass m_compressWorker;

	volatile const BYTE* m_source;
	volatile BYTE* m_dest;
	volatile BYTE* m_buffer;
	volatile size_t m_width;
	volatile size_t m_height;
	volatile size_t m_length;	// uncompressed data length
	volatile size_t m_size;		// compressed data length
	volatile unsigned int m_format;
	unsigned int m_priority;
};

DWORD WINAPI EncodeWorkerTread(LPVOID i);
DWORD WINAPI DecodeWorkerThread(LPVOID i);