timer提供线程安全的可能

librf/src/event_v2.cpp

@@ -26,6 +26,8 @@ RESUMEF_NS
 			if (oldValue != nullptr && _value.compare_exchange_strong(oldValue, nullptr, std::memory_order_acq_rel))
 			{
 				*oldValue = false;
+				_thandler.stop();
+
 				this->_coro = nullptr;
 			}
 		}
@@ -36,6 +38,7 @@ RESUMEF_NS
 			if (oldValue != nullptr && _value.compare_exchange_strong(oldValue, nullptr, std::memory_order_acq_rel))
 			{
 				*oldValue = true;
+				_thandler.stop();
 
 				assert(this->_scheduler != nullptr);
 				if (this->_coro)
@@ -52,6 +55,7 @@ RESUMEF_NS
 			if (oldValue != nullptr && _value.compare_exchange_strong(oldValue, nullptr, std::memory_order_acq_rel))
 			{
 				*oldValue = false;
+				_thandler.reset();
 
 				assert(this->_scheduler != nullptr);
 				if (this->_coro)

librf/src/event_v2.h

@@ -37,4 +37,18 @@ RESUMEF_NS
 			timeout_awaiter wait_until_(const clock_type::time_point& tp) const noexcept;
 		};
 	}
+
+	template<class _Rep, class _Period>
+	auto wait_for(event_v2::event_t& e, const std::chrono::duration<_Rep, _Period>& dt)
+	{
+		return e.wait_for(dt);
+	}
+			template<class _Clock, class _Duration>
+	auto wait_until(event_v2::event_t& e, const std::chrono::time_point<_Clock, _Duration>& tp)
+	{
+		return e.wait_until(tp);
+	}
+
+	//when_all_for(dt, args...) -> when_all(wait_for(args, dt)...)
+	//就不再单独为每个支持超时的类提供when_all_for实现了。借助when_all和非成员的wait_for实现
 }

librf/src/event_v2.inl

@@ -91,6 +91,7 @@ RESUMEF_NS
 
 			//为浸入式单向链表提供的next指针
 			counted_ptr<state_event_t> _next = nullptr;
+			timer_handler _thandler;
 		private:
 			//_value引用awaitor保存的值，这样可以尽可能减少创建state的可能。而不必进入没有state就没有value实体被用于返回。
 			//在调用on_notify()或on_timeout()任意之一后，置为nullptr。
@@ -191,7 +192,7 @@ RESUMEF_NS
 
 				_event->add_wait_list(_state.get());
 
-				(void)sch->timer()->add(_tp, [_state=_state](bool canceld)
+				_state->_thandler = sch->timer()->add_handler(_tp, [_state=_state](bool canceld)
 					{
 						if (!canceld)
 							_state->on_timeout();

librf/src/timer.cpp

@@ -26,7 +26,10 @@ RESUMEF_NS
 
 	void timer_manager::clear()
 	{
+		std::unique_lock<spinlock> __lock(_added_mtx);
 		auto _atimer = std::move(_added_timers);
+		__lock.unlock();
+
 		for (auto& sptr : _atimer)
 			call_target_(sptr, true);
 
@@ -39,6 +42,8 @@ RESUMEF_NS
 	{
 		assert(sptr);
 		assert(sptr->st == timer_target::State::Invalid);
+
+		scoped_lock<spinlock> __lock(_added_mtx);
 #if _DEBUG
 		assert(sptr->_manager == nullptr);
 		sptr->_manager = this;
@@ -64,9 +69,16 @@ RESUMEF_NS
 
 	void timer_manager::update()
 	{
+		{
+			std::unique_lock<spinlock> __lock(_added_mtx);
+
 			if (_added_timers.size() > 0)
 			{
-			for (auto & sptr : _added_timers)
+				auto _atimer = std::move(_added_timers);
+				_added_timers.reserve(128);
+				__lock.unlock();
+
+				for (auto& sptr : _atimer)
 				{
 					if (sptr->st == timer_target::State::Added)
 					{
@@ -79,17 +91,15 @@ RESUMEF_NS
 						call_target_(sptr, true);
 					}
 				}
-
+			}
-			_added_timers.clear();
 		}
 
 		if (_runing_timers.size() > 0)
 		{
 			auto now_ = clock_type::now();
-			timer_map_type _timers = std::move(_runing_timers);
 
-			auto iter = _timers.begin();
+			auto iter = _runing_timers.begin();
-			for (; iter != _timers.end(); ++iter)
+			for (; iter != _runing_timers.end(); ++iter)
 			{
 				auto & kv = *iter;
 				if (kv.first > now_)
@@ -97,9 +107,8 @@ RESUMEF_NS
 
 				call_target_(kv.second, kv.second->st == timer_target::State::Invalid);
 			}
-			_timers.erase(_timers.begin(), iter);
 
-			_runing_timers = std::move(_timers);
+			_runing_timers.erase(_runing_timers.begin(), iter);
 		}
 	}
 }

librf/src/timer.h

@@ -80,6 +80,7 @@ RESUMEF_NS
 		typedef std::vector<timer_target_ptr> timer_vector_type;
 		typedef std::multimap<clock_type::time_point, timer_target_ptr> timer_map_type;
 	protected:
+		spinlock _added_mtx;
 		timer_vector_type	_added_timers;
 	public:
 		timer_map_type		_runing_timers;
@@ -112,7 +113,7 @@ RESUMEF_NS
 
 		inline bool empty() const
 		{
-			return _added_timers.empty() && _runing_timers.empty();
+			return _runing_timers.empty() && _added_timers.empty();
 		}
 		void clear();
 		void update();