fix ~workerpool by using AutoContext

Author: lihuiba

thread/test/test-pool.cpp

@@ -247,6 +247,21 @@ TEST(workpool, async_work_lambda_threadpool) {
     LOG_INFO("DONE");
 }
 
+TEST(workpool, std_context) {
+    std::thread test([]{
+        WorkPool pool(8);
+        EXPECT_EQ(pool.get_vcpu_num(), 8);
+        photon::spinlock lock;
+        auto func = new auto([&]{ lock.lock(); });
+        pool.call<StdContext>(*func);
+        EXPECT_TRUE(lock.locked());
+        lock.unlock();
+        pool.async_call(func);
+        while(!lock.locked());
+    });
+    test.join();
+}
+
 TEST(workpool, async_work_lambda_threadpool_append) {
     std::unique_ptr<WorkPool> pool(new WorkPool(0, 0, 0, 0));
 

thread/thread.h

@@ -219,6 +219,9 @@ namespace photon
             return (likely(!load()) &&
                     likely(!xchg())) ? 0 : -1;
         }
+        bool locked() const {
+            return _lock;
+        }
         void unlock() {
             _lock.store(false, std::memory_order_release);
         }

thread/workerpool.cpp

@@ -54,7 +54,7 @@ class WorkPool::impl {
     }
 
     ~impl() { // avoid depending on photon to make it destructible wihout photon
-        for (auto num = vcpus.size(); num; --num) enqueue({}, PhotonContext());
+        for (auto num = vcpus.size(); num; --num) enqueue({});
         for (auto &worker : owned_std_threads) worker.join();
         while (vcpus.size()) std::this_thread::yield();
     }