fix ya.make

1 files changed, 41 insertions, 0 deletions

diff --git a/library/cpp/neh/jobqueue.h b/library/cpp/neh/jobqueue.h
new file mode 100644
index 00000000000..ec86458cf05
--- /dev/null
+++ b/library/cpp/neh/jobqueue.h
@@ -0,0 +1,41 @@
+#pragma once
+
+#include <library/cpp/coroutine/engine/impl.h>
+
+#include <util/generic/yexception.h>
+#include <util/stream/output.h>
+
+namespace NNeh {
+    class IJob {
+    public:
+        inline void operator()(TCont* c) noexcept {
+            try {
+                DoRun(c);
+            } catch (...) {
+                Cdbg << "run " << CurrentExceptionMessage() << Endl;
+            }
+        }
+
+        virtual ~IJob() {
+        }
+
+    private:
+        virtual void DoRun(TCont* c) = 0;
+    };
+
+    class IJobQueue {
+    public:
+        template <class T>
+        inline void Schedule(T req) {
+            ScheduleImpl(req.Get());
+            Y_UNUSED(req.Release());
+        }
+
+        virtual void ScheduleImpl(IJob* job) = 0;
+
+        virtual ~IJobQueue() {
+        }
+    };
+
+    IJobQueue* JobQueue();
+}