1

// thread safe que

     2

// Tochinski Leonid, Chatten Associayes, Inc.

     3

#pragma once

     4

#include <deque>

     5

#include "AutoReleaseCS.h"

     6

     7

template<typename type>

     8

class async_access_que

     9

   {

    10

   public:

    11

      async_access_que()

    12

         {

    13

         ::InitializeCriticalSection(&m_cs);

    14

         }

    15

      ~async_access_que()

    16

         {

    17

         ::DeleteCriticalSection(&m_cs);

    18

         }

    19

    20

      void append(const type& data)

    21

         {

    22

         AutoReleaseCS acs(m_cs);

    23

         m_data.push_back(data);

    24

         }

    25

    26

      bool extract_top(type& data)

    27

         {

    28

         AutoReleaseCS acs(m_cs);

    29

         if (m_data.empty())

    30

            return false;

    31

          data = m_data.front();

    32

          m_data.pop_front();

    33

         return true;

    34

         }

    35

    36

      void clear()

    37

         {

    38

         AutoReleaseCS acs(m_cs);

    39

         m_data.clear();

    40

         }

    41

    42

   protected:

    43

      std::deque<type> m_data;

    44

      CRITICAL_SECTION m_cs;

    45

   };