##// END OF EJS Templates
implab » ImplabNet
RSS
DispatchPool works again, but performance is poor in some cases
DispatchPool works again, but performance is poor in some cases
cin - - Load All Authors

File last commit:

r12:eb418ba8275b promises
r21:6a56df4ec59e promises
Show More
TaskController.cs
132 lines | 3.4 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, added WorkerPool
 r12 class TaskController: IProgressNotifier, ITaskController, ICancellable
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
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, added WorkerPool
 r12 public bool Cancelled {
get {
lock (m_lock)
return m_cancelled;
}
}
public bool Cancel() {
lock (m_lock) {
if (!m_cancelled) {
m_cancelled = true;
return true;
} else {
return false;
}
}
}
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));
}
}
}
}