// This file is part of Desktop App Toolkit,
// a set of libraries for developing nice desktop applications.
//
// For license and copyright information please follow this link:
// https://github.com/desktop-app/legal/blob/master/LEGAL
//
#pragma once

#include <crl/common/crl_common_object_async.h>
#include <crl/common/crl_common_list.h>
#include <condition_variable>

namespace crl {
namespace details {

class thread_policy {
protected:
	thread_policy();

	template <typename Callable>
	void async_plain(Callable &&callable) const;

private:
	void run();
	void wake_async() const;

	mutable std::mutex _mutex;
	mutable std::condition_variable _variable;
	mutable details::list _list;
	mutable std::atomic_flag _queued = ATOMIC_FLAG_INIT;

};

template <typename Callable>
void thread_policy::async_plain(Callable &&callable) const {
	if (_list.push_is_first(std::forward<Callable>(callable))) {
		wake_async();
	}
}

} // namespace details

template <typename Type>
using weak_on_thread = details::weak_async<details::thread_policy, Type>;

template <typename Type>
using object_on_thread = details::object_async<details::thread_policy, Type>;

} // namespace