MCPcopy Create free account
hub / github.com/apple/foundationdb / startThreadF

Function startThreadF

flow/Net2.actor.cpp:2133–2146  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2131
2132template <class F>
2133THREAD_HANDLE startThreadF(F&& func) {
2134 struct Thing {
2135 F f;
2136 Thing(F&& f) : f(std::move(f)) {}
2137 THREAD_FUNC start(void* p) {
2138 Thing* self = (Thing*)p;
2139 self->f();
2140 delete self;
2141 THREAD_RETURN;
2142 }
2143 };
2144 Thing* t = new Thing(std::move(func));
2145 return g_network->startThread(Thing::start, t);
2146}
2147
2148TEST_CASE("/flow/Net2/ThreadSafeQueue/Interface") {
2149 ThreadSafeQueue<int> tq;

Callers 1

Net2.actor.cppFile · 0.85

Calls 2

moveFunction · 0.85
startThreadMethod · 0.45

Tested by

no test coverage detected