Provide multi-threaded processing.

TextMatching/MatchText/BlockingQueue.h

@@ -0,0 +1,44 @@
+#pragma once
+
+template <typename T> class BlockingQueue {
+  std::condition_variable _cvCanPop;
+  std::mutex _sync;
+  std::queue<T> _qu;
+  bool _bShutdown = false;
+
+public:
+  void Push(const T& item)
+  {
+    {
+      std::unique_lock<std::mutex> lock(_sync);
+      _qu.push(item);
+    }
+    _cvCanPop.notify_one();
+  }
+
+  void RequestShutdown() {
+    {
+      std::unique_lock<std::mutex> lock(_sync);
+      _bShutdown = true;
+    }
+    _cvCanPop.notify_all();
+  }
+
+  bool Pop(T &item) {
+    std::unique_lock<std::mutex> lock(_sync);
+    for (;;) {
+      if (_qu.empty()) {
+        if (_bShutdown) {
+          return false;
+        }
+      }
+      else {
+        break;
+      }
+      _cvCanPop.wait(lock);
+    }
+    item = std::move(_qu.front());
+    _qu.pop();
+    return true;
+  }
+};

TextMatching/MatchText/MatchText.vcxproj

@@ -147,6 +147,7 @@
     </Link>
   </ItemDefinitionGroup>
   <ItemGroup>
+    <ClInclude Include="BlockingQueue.h" />
     <ClInclude Include="Statistics.h" />
     <ClInclude Include="stdafx.h" />
     <ClInclude Include="targetver.h" />

TextMatching/MatchText/MatchText.vcxproj.filters

@@ -27,6 +27,9 @@
     <ClInclude Include="Utils.h">
       <Filter>Header Files</Filter>
     </ClInclude>
+    <ClInclude Include="BlockingQueue.h">
+      <Filter>Header Files</Filter>
+    </ClInclude>
   </ItemGroup>
   <ItemGroup>
     <ClCompile Include="stdafx.cpp">