| 171 | |
| 172 | template <class T> |
| 173 | Y_WARN_UNUSED_RESULT bool AddFunc(T&& func) { |
| 174 | THolder<IObjectInQueue> wrapper(MakeThrFuncObj(std::forward<T>(func))); |
| 175 | bool added = Add(wrapper.Get()); |
| 176 | if (added) { |
| 177 | Y_UNUSED(wrapper.Release()); |
| 178 | } |
| 179 | return added; |
| 180 | } |
| 181 | |
| 182 | bool AddAndOwn(THolder<IObjectInQueue> obj) Y_WARN_UNUSED_RESULT; |
| 183 | virtual void Start(size_t threadCount, size_t queueSizeLimit = 0) = 0; |
no test coverage detected