File latch.h

Defines

DEFAULT_LATCH_TIMEOUT_MS

namespace faabric

namespace util

class Latch : public std::enable_shared_from_this<Latch>

Public Functions

explicit Latch(int countIn, int timeoutMsIn)

void wait()

Public Static Functions

static std::shared_ptr<Latch> create(int count, int timeoutMs = DEFAULT_LATCH_TIMEOUT_MS)

Private Members

int count

int waiters = 0

int timeoutMs

std::mutex mx

std::condition_variable cv