implab/ImplabNet Commit - r257:440801d88019

working on runnable components

cin -

r257:440801d88019 v3

parent child

Context file:

r257:440801d88019

Collapse all files

Implab/Components/RunnableComponent.cs +47 -6

                  /// This class provides a basic lifecycle from the creation to the
                  /// termination of the component.
                  /// </remarks>
-                 public class RunnableComponent : IAsyncComponent, IRunnable, IInitializable, IDisposable {
+                 public abstract class RunnableComponent : IAsyncComponent, IRunnable, IInitializable, IDisposable {
                      /// <summary>
                      /// This class bounds <see cref="CancellationTokenSource"/> lifetime to the task,
                      ExecutionState m_state;
+                     /// <summary>
+                     /// Объект синхронизации используется для обеспечения совместного доступа
+                     /// клиента компоненты и процессов, протекающих внутри компоненты, к общему
+                     /// состоянию, т.е.true таким свойствам, как <see cref="State"/>,
+                     /// <see cref="LastError"/>. Обработчики события <see cref="StateChanged"/>
+                     /// вызываются уже с установленной блокировкой, поэтому дополнительная
+                     /// синхронизация не требуется.
+                     /// </summary>
+                     public object SynchronizationObject { get { return m_lock; } }
                      protected RunnableComponent(bool initialized) {
                          State = initialized ? ExecutionState.Ready : ExecutionState.Created;
                      public Exception LastError { get; private set; }
+                     /// <summary>
+                     /// Событие изменения состояния компоненты.see Обработчики данного события
+                     /// вызываются внутри блокировки <see cref="SynchronizationObject"/> и должны
+                     /// выполняться максимально быстро.
+                     /// </summary>
                      public event EventHandler<StateChangeEventArgs> StateChanged;
                      /// <summary>
                      /// </remarks>
                      public void Dispose() {
                          bool dispose = false;
+                         lock (SynchronizationObject) {
+                             if (m_state != ExecutionState.Disposed) {
+                                 dispose = true;
+                                 m_state = ExecutionState.Disposed;
+                                 m_cookie = new object();
+                             }
+                         }
                          if (dispose) {
                              Dispose(true);
                              GC.SuppressFinalize(this);
                      public void Initialize() {
                          var cookie = new object();
                          if (MoveInitialize(cookie))
-                             ScheduleTask(InitializeInternalAsync, CancellationToken.None, cookie);
+                             Safe.NoWait(ScheduleTask(InitializeInternalAsync, CancellationToken.None, cookie));
                          else
                              throw new InvalidOperationException();
                      }
                      public void Start(CancellationToken ct) {
                          var cookie = new object();
                          if (MoveStart(cookie))
-                             ScheduleTask(StartInternalAsync, ct, cookie);
+                             Safe.NoWait(ScheduleStartAndRun(ct, cookie));
                          else
                              throw new InvalidOperationException();
                      }
+                     async Task ScheduleStartAndRun(CancellationToken ct, object cookie) {
+                         try {
+                             await ScheduleTask(StartInternalAsync, ct, cookie);
+                             RunInternal();
+                         } catch (Exception err) {
+                             Fail(err);
+                         }
+                     }
                      protected virtual Task StartInternalAsync(CancellationToken ct) {
                          return Task.CompletedTask;
                      }
+                     /// <summary>
+                     /// This method is called after the component is enetered running state,
+                     /// use this method to
+                     /// </summary>
+                     protected virtual void RunInternal() {
+                     }
                      public void Stop(CancellationToken ct) {
                          var cookie = new object();
                          if (MoveStop(cookie))
-                             ScheduleTask(StopAsync, ct, cookie);
+                             Safe.NoWait(ScheduleTask(StopAsync, ct, cookie));
                          else
                              throw new InvalidOperationException();
                      }
                          }
                      }
-                     void ScheduleTask(Func<CancellationToken, Task> next, CancellationToken ct, object cookie) {
+                     Task ScheduleTask(Func<CancellationToken, Task> next, CancellationToken ct, object cookie) {
-                         m_current = AsyncOperationDescriptor.Create(async (x) => {
+                         var op = AsyncOperationDescriptor.Create(async (x) => {
                              try {
                                  await next(x);
                                  MoveSuccess(cookie);
                                  MoveFailed(e, cookie);
                              }
                          }, ct);
+                         m_current = op;
+                         return op.Task;
                      }
                      #endregion

General Comments 3

sergey

|

Auto status change to "Under Review"

sergey

|

ok, latest stable version should be in default

Write
Preview

You need to be logged in to leave comments. Login now

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages