Fea #29, 消除Chromium项目中Windows XP不支持的线程池创建API

  - 添加 CreateThreadpool
  - 添加 CloseThreadpool
  - 添加 SetThreadpoolThreadMaximum
  - 添加 SetThreadpoolThreadMinimum
  - 添加 CallbackMayRunLong

ThunksList.md

@@ -63,6 +63,11 @@
 | StartThreadpoolIo                          | 不存在时，内部实现。
 | CancelThreadpoolIo                         | 不存在时，内部实现。
 | WaitForThreadpoolIoCallbacks               | 不存在时，调用WaitForSingleObject。
+| CreateThreadpool                           | 不存在时，内部实现。
+| CloseThreadpool                            | 不存在时，内部实现。
+| SetThreadpoolThreadMaximum                 | 不存在时，内部实现，自己控制最大并行数量。
+| SetThreadpoolThreadMinimum                 | 不存在时，忽略，并总是返回成功。
+| CallbackMayRunLong                         | 不存在时，自己估算系统剩余可用线程数。
 
 ## api-ms-win-core-winrt-l1-1-0.dll
 | 函数                                       | Fallback

src/Shared/InterlockedQueue.h

@@ -0,0 +1,80 @@
+#pragma once
+
+namespace YY::Thunks::internal
+{
+    namespace
+    {
+        template<class Entry, size_t kMaxBlockSize>
+        class InterlockedQueue
+        {
+        private:
+            struct Block
+            {
+                size_t uLastReadIndex = 0;
+                size_t uLastWriteIndex = 0;
+                Block* pNextBlock = nullptr;
+                Entry* arrLoopBuffer[kMaxBlockSize];
+
+                bool IsEmpty()
+                {
+                    return uLastReadIndex == uLastWriteIndex;
+                }
+
+                bool IsFull()
+                {
+                    return uLastReadIndex + kMaxBlockSize == uLastWriteIndex;
+                }
+            };
+
+            Block* pFirstReadBlock = nullptr;
+            Block* pLastWriteBlock = nullptr;
+
+        public:
+            Entry* Pop() noexcept
+            {
+                if (!pFirstReadBlock)
+                    return nullptr;
+
+                for (;;)
+                {
+                    // 当前块任然有元素？
+                    if (!pFirstReadBlock->IsEmpty())
+                    {
+                        auto _pTmp = pFirstReadBlock->arrLoopBuffer[pFirstReadBlock->uLastReadIndex % kMaxBlockSize];
+                        pFirstReadBlock->uLastReadIndex += 1;
+                        return _pTmp;
+                    }
+
+                    // 尝试流转到下一块
+                    if (!pFirstReadBlock->pNextBlock)
+                        return nullptr;
+
+                    auto _pPendingDelete = pFirstReadBlock;
+                    pFirstReadBlock = pFirstReadBlock->pNextBlock;
+                    Delete(_pPendingDelete);
+                }
+
+                return nullptr;
+            }
+
+            void Push(_In_ Entry* _pEntry)
+            {
+                if (!pLastWriteBlock)
+                {
+                    pFirstReadBlock = pLastWriteBlock = New<Block>();
+                }
+
+                // 如果满了就尝试链接到下一块
+                if (pLastWriteBlock->IsFull())
+                {
+                    auto _pNextBlock = New<Block>();
+                    pLastWriteBlock->pNextBlock = _pNextBlock;
+                    pLastWriteBlock = _pNextBlock;
+                }
+
+                pLastWriteBlock->arrLoopBuffer[pLastWriteBlock->uLastWriteIndex % kMaxBlockSize] = _pEntry;
+                pLastWriteBlock->uLastWriteIndex += 1;
+            }
+        };
+    }
+}