wait_proxy.h

#pragma once

 
#include <yt/cpp/mapreduce/interface/common.h>
 
#include <util/datetime/base.h>
 
namespace NThreading {
template <typename T>
class TFuture;
}
 
class TSystemEvent;
class TCondVar;
class TMutex;
 
namespace NYT {


class IWaitProxy
    : public TThrRefBase
{
public:
    virtual ~IWaitProxy() = default;

    virtual bool WaitFuture(const ::NThreading::TFuture<void>& future, TDuration timeout) = 0;

    virtual bool WaitEvent(TSystemEvent& event, TDuration timeout) = 0;

    virtual bool WaitCondVar(TCondVar& condVar, TMutex& mutex, TDuration timeout) = 0;

    virtual void Sleep(TDuration timeout) = 0;
};

 
} // namespace NYT