MCPcopy Create free account
hub / github.com/4paradigm/OpenMLDB / AddTask

Method AddTask

src/base/taskpool.hpp:62–70  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

60 }
61
62 void AddTask(const Task& task) {
63 std::unique_lock<std::mutex> lock(mutex_);
64 while (queue_.full() && !stop_) {
65 queue_cv_.wait(lock);
66 }
67 if (stop_) return;
68 queue_.put(task);
69 work_cv_.notify_one();
70 }
71
72 private:
73 static void* ThreadWrapper(void* arg) {

Callers 15

UpdateTabletsMethod · 0.80
ProcessTaskMethod · 0.80
MakeSnapshotNSMethod · 0.80
DropTableFunMethod · 0.80
CreateTableMethod · 0.80
CreateTableInternelMethod · 0.80
SchedMakeSnapshotMethod · 0.80
OnLockedMethod · 0.80
AddReplicaClusterMethod · 0.80
AddReplicaClusterByNsMethod · 0.80
SwitchModeMethod · 0.80

Calls 2

fullMethod · 0.80
putMethod · 0.45

Tested by 1

TEST_FFunction · 0.64