##// END OF EJS Templates
implab » ImplabNet
RSS
Reworked cancelation handling, if the cancel handler isn't specified the OperationCanceledException will be handled by the error handler...
Reworked cancelation handling, if the cancel handler isn't specified the OperationCanceledException will be handled by the error handler Any unhandled OperationCanceledException will cause the promise cancelation
cin - - Load All Authors

File last commit:

r138:f75cfa58e3d4 v2
r187:dd4a3590f9c6 ref20160224
Show More
TaskController.cs
143 lines | 3.7 KiB | text/x-csharp | CSharpLexer
/ Implab / TaskController.cs
History | Source | Raw |Copy content |Copy permalink
cin
inital progress handling
 r7 using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace Implab
{
/// <summary>
/// This class allows to interact with asyncronuos task.
/// </summary>
/// <remarks>
/// Members of this object are thread safe.
/// </remarks>
cin
refactoring
 r25 public class TaskController: IProgressNotifier, ITaskController
cin
inital progress handling
 r7 {
cin
implemeted new cancellable promises concept
 r10 readonly object m_lock;
cin
inital progress handling
 r7 string m_message;
float m_current;
float m_max;
cin
refactoring, added WorkerPool
 r12 bool m_cancelled;
cin
refactoring
 r25 public event EventHandler Cancelled;
cin
inital progress handling
 r7 public event EventHandler<ValueEventArgs<string>> MessageUpdated;
public event EventHandler<ValueEventArgs<float>> ProgressUpdated;
public event EventHandler<ProgressInitEventArgs> ProgressInit;
public TaskController()
{
m_lock = new Object();
}
public string Message
{
get
{
lock (m_lock)
return m_message;
}
set
{
lock (m_lock)
{
m_message = value;
OnMessageUpdated();
}
}
}
public float CurrentProgress
{
get
{
lock (m_lock)
return m_current;
}
set
{
lock (m_lock)
{
var prev = m_current;
m_current = value;
if (m_current >= m_max)
m_current = m_max;
if (m_current != prev)
OnProgressUpdated();
}
}
}
public void InitProgress(float current, float max, string message)
{
if (max < 0)
throw new ArgumentOutOfRangeException("max");
if (current < 0 || current > max)
throw new ArgumentOutOfRangeException("current");
lock(m_lock) {
m_current = current;
m_max = max;
m_message = message;
OnProgressInit();
}
}
cin
refactoring
 r25 public bool IsCancelled {
cin
refactoring, added WorkerPool
 r12 get {
lock (m_lock)
return m_cancelled;
}
}
cin
Refactoring of the IPromise<T> interface...
 r76 public void Cancel() {
cin
refactoring, added WorkerPool
 r12 lock (m_lock) {
cin
Refactoring of the IPromise<T> interface...
 r76 if (!m_cancelled)
cin
refactoring, added WorkerPool
 r12 m_cancelled = true;
}
}
cin
added ICancellable.Cancel(Exception) to allow specify the reason of cancellation
 r138 public void Cancel(Exception reason) {
lock (m_lock) {
if (!m_cancelled)
m_cancelled = true;
}
}
cin
refactoring
 r25 protected virtual void OnCancelled() {
var temp = Cancelled;
if (temp != null) {
temp(this,new EventArgs());
}
}
cin
inital progress handling
 r7 protected virtual void OnMessageUpdated()
{
var temp = MessageUpdated;
if (temp != null)
{
temp(this, new ValueEventArgs<string>(m_message));
}
}
protected virtual void OnProgressUpdated()
{
var temp = ProgressUpdated;
if (temp != null)
{
temp(this,new ValueEventArgs<float>(m_current));
}
}
protected virtual void OnProgressInit()
{
var temp = ProgressInit;
if (temp != null)
{
temp(this, new ProgressInitEventArgs(m_current,m_max, m_message));
}
}
}
}