Последовательное логирование в отдельном потоке

pyhta4og: Это было сделано для того, чтобы очередь не отжирала всю память. Это понятно. Вызов я не о...

2013-02-18T10:50:39Z

pyhta4og: Это было сделано для того, чтобы очередь не отжирала всю память. Это понятно. Вызов я не отменил, а заменил его пинанием таймера. pyhta4og: Помимо этого есть режим MaxMessages=-1 когда логирование идет синхронно. Это сделано для того чтобы производить отладку. Иначе получится что вы уже на бреакпойнт в коде робота встали, а логи еще в файл не записались. Для отладки нужно не костыли городить, а, например, сделать класс-заглушку, которая будет писать, куда надо и как надо, или просто сделать явный ключ bool OneThread.

VassilSanych: Кстати. У LogManager есть такой косяк: когда количество сообщений превышает заданный м...

2013-02-18T10:43:37Z

VassilSanych: Кстати. У LogManager есть такой косяк: когда количество сообщений превышает заданный максимум (т.е. как раз когда система очень сильно нагружена), логирование запускается в потоке вызова.

Это было сделано для того, чтобы очередь не отжирала всю память.

Помимо этого есть режим MaxMessages=-1 когда логирование идет синхронно. Это сделано для того чтобы производить отладку. Иначе получится что вы уже на бреакпойнт в коде робота встали, а логи еще в файл не записались.

Изменил буфер сообщений на конкурентную очередь, убрал все локи, принудительный запуск логирования з...

2013-02-18T09:11:25Z

Изменил буфер сообщений на конкурентную очередь, убрал все локи, принудительный запуск логирования заменил перещёлкиванием таймера. Последнее исправление не тестировал.

Кстати. У LogManager есть такой косяк: когда количество сообщений превышает заданный максимум (т.е. ...

2013-02-18T09:07:16Z

Кстати. У LogManager есть такой косяк: когда количество сообщений превышает заданный максимум (т.е. как раз когда система очень сильно нагружена), логирование запускается в потоке вызова.

Ага. Понял. Пишет пачками по таймеру (вспомнил, почему у меня пропадало сообщение о завершении работ...

2013-02-17T17:06:12Z

Ага. Понял. Пишет пачками по таймеру (вспомнил, почему у меня пропадало сообщение о завершении работы). И всё-таки лочит основной поток при добавлении сообщения в список. Очередь была бы производительнее.

VassilSanych: Mikhail Sukhov: Так ведь сейчас уже в 4.1 логирование отделено от основного потока. Гд...

2013-02-17T16:52:37Z

VassilSanych:

Mikhail Sukhov: Так ведь сейчас уже в 4.1 логирование отделено от основного потока. Где? Я не нашёл.

LogManager.cs Это к слову о важности взаимодействия.

Mikhail Sukhov: Так ведь сейчас уже в 4.1 логирование отделено от основного потока. Где? Я не нашёл....

2013-02-17T16:35:51Z

Mikhail Sukhov: Так ведь сейчас уже в 4.1 логирование отделено от основного потока. Где? Я не нашёл.

VassilSanych: Логирование включает файловые и другие системные операции. Это в любом случае замедляе...

2013-02-17T16:26:07Z

VassilSanych: Логирование включает файловые и другие системные операции. Это в любом случае замедляет выполнение основных алгоритмов. При том, что логирование - операция как раз совершенно не критичная к времени запуска, в отличие от торговых операций. Это не решение проблемы, это - архитектурная плюшка (о чём и сказано в комментарии темы). PS Должно было быть указано, но почему-то не было. Исправил :)

Так ведь сейчас уже в 4.1 логирование отделено от основного потока.

Да и вообще была проблема того что блокирование потока логов приводило к блокированию всей системы. ...

2013-02-17T16:02:45Z

Да и вообще была проблема того что блокирование потока логов приводило к блокированию всей системы. :). С такой плюшкой думаю сего не повторится.

Ещё одна доработка исходников: Разгрузка основного потока от логирования. Возможность изоляции от си...

2013-02-17T14:02:12Z

Ещё одна доработка исходников: Разгрузка основного потока от логирования. Возможность изоляции от системных ресурсов, связанных с логированием.

public abstract class BaseLogReceiver<TParent> : BaseLogSource<TParent>, ILogReceiver
	{
		/// <summary>
		/// Инициализировать <see cref="BaseLogReceiver{TParent}"/>.
		/// </summary>
		protected BaseLogReceiver()
		{
		}

		void ILogReceiver.AddLog(LogMessage message)
		{
			LoggingQueue.AddLogAction(()=>RaiseLog(message));
		}
	}


	/// <summary>
	///  Логирование в отдельном параллельном потоке
	/// </summary>
	public class LoggingQueue
	{
		//если понадобится подменять реализацию
		public static LoggingQueue Instance { get; set; }


		static LoggingQueue()
		{
			Instance = new LoggingQueue();
		}


		public LoggingQueue()
		{
			StartThread();
		}


		/// <summary>
		///  Запуск отдельного параллельного потока логирования
		/// </summary>
		protected virtual void StartThread()
		{
			_loggingQueue = new ConcurrentQueue<Action>();
			_waitLog = new AutoResetEvent(false);
			Task.Run(() => DoLoggingListen());
		}


		private ConcurrentQueue<Action> _loggingQueue;
		private AutoResetEvent _waitLog;


		/// <summary>
		///		Добавление записи в лог
		/// </summary>
		/// <param name="action"></param>
		public static void AddLogAction(Action action)
		{
			Instance.AddAction(action);
		}


		/// <summary>
		///  Добавление действия записи в лог в очередь потока логирования
		/// </summary>
		/// <param name="action"></param>
		public virtual void AddAction(Action action)
		{
			_loggingQueue.Enqueue(action);
			_waitLog.Set();
		}


		/// <summary>
		///  Чтение очереди действий логирования
		/// </summary>
		protected virtual void DoLoggingListen()
		{
			do
			{
				Action logAction;
				if (_loggingQueue.TryDequeue(out logAction))
					logAction.Invoke();
				else
					_waitLog.WaitOne();
			} while (!_stopped);
		}

		private bool _stopped;
		/// <summary>
		///  Создание условий окончания работы прослушивания очереди
		/// </summary>
		public virtual void Stop()
		{
			_stopped = true;
			_waitLog.Set();
		}

	}


	/// <summary>
	///  Затычка логирования (может понадобиться для тестирования)
	/// </summary>
	public class LoggingQueueMock: LoggingQueue
	{
		//protected override void DoLoggingListen()
		//{
		//}

		public override void AddAction(Action action)
		{
		}

		protected override void StartThread()
		{
		}
	}

Кстати, можно что-то придумать и для затыкания LoggingHelper.Now. Потому что привязка кода к ресурсам системного времени - это совсем не TDD.

Критика просто жизненно необходима :)

PS Беда какая-то с описанием темы. Ломается.

Логирование включает файловые и другие системные операции. Это в любом случае замедляет выполнение о...

2013-02-17T15:19:29Z

Логирование включает файловые и другие системные операции. Это в любом случае замедляет выполнение основных алгоритмов. При том, что логирование - операция как раз совершенно не критичная к времени запуска, в отличие от торговых операций. Это не решение проблемы, это - архитектурная плюшка (о чём и сказано в комментарии темы). PS Должно было быть указано, но почему-то не было. Исправил :)

VassilSanych: Критика просто жизненно необходима :) Начнем с того, что обычно формулируют проблему (...

2013-02-17T15:14:21Z

VassilSanych: Критика просто жизненно необходима :)

Начнем с того, что обычно формулируют проблему (типа как перед чтением стихов произносят название произведения и автора). Как решалась проблема?

Для примера. Я выделял логирование в отдельный поток, чтобы разгрузить основной поток торговли. Была проблема с перформансом логирования в файл, была решена с помощью параллельного потока.