@@ -28,7 +28,7 @@ class PyProducerConsumer
2828 HANDLE m_shutdown;
2929 std::queue<std::shared_ptr<DataT> > m_queue;
3030 DWORD m_dwThreadId;
31- HANDLE m_hThread ;
31+ HANDLE m_hConsumerThread ;
3232 bool m_consuming;
3333
3434 void consumer ();
@@ -39,7 +39,7 @@ class PyProducerConsumer
3939
4040template <typename DataT>
4141PyProducerConsumer<DataT>::PyProducerConsumer()
42- : m_hThread (NULL ),
42+ : m_hConsumerThread (NULL ),
4343 m_dwThreadId (NULL ),
4444 m_consuming(false )
4545{
@@ -67,11 +67,11 @@ template <typename DataT>
6767void PyProducerConsumer<DataT>::stopConsumer()
6868{
6969 SetEvent (m_shutdown);
70- if (m_hThread )
70+ if (m_hConsumerThread )
7171 {
72- WaitForSingleObject (m_hThread , INFINITE);
73- CloseHandle (m_hThread );
74- m_hThread = NULL ;
72+ WaitForSingleObject (m_hConsumerThread , INFINITE);
73+ CloseHandle (m_hConsumerThread );
74+ m_hConsumerThread = NULL ;
7575 }
7676}
7777
@@ -105,9 +105,9 @@ bool PyProducerConsumer<DataT>::produce(const std::shared_ptr<DataT>& data)
105105template <typename DataT>
106106void PyProducerConsumer<DataT>::startConsumer()
107107{
108- if (!m_hThread )
108+ if (!m_hConsumerThread )
109109 {
110- m_hThread = CreateThread (NULL , 0 , (LPTHREAD_START_ROUTINE)threadStart, this , 0 , &m_dwThreadId);
110+ m_hConsumerThread = CreateThread (NULL , 0 , (LPTHREAD_START_ROUTINE)threadStart, this , 0 , &m_dwThreadId);
111111 }
112112}
113113
0 commit comments