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