TaskSetProgress Method (Int32, Object) |
Namespace: AGI.Parallel.Infrastructure
using System; using System.Collections.Generic; using System.Diagnostics; using AGI.Parallel.Client; using AGI.Parallel.Infrastructure; namespace CodeSamples { class Program { static void Main(string[] args) { using (IJobScheduler scheduler = new ClusterJobScheduler("localhost")) { scheduler.Connect(); Job job = scheduler.CreateJob(); job.AddTask(new ProgressTask()); // Subscribe to TaskProgressUpdated job.TaskProgressUpdated += new EventHandler<TaskProgressEventArgs>(Job_TaskProgressUpdated); job.Submit(); job.WaitUntilDone(); } /* * The output of the application should resemble: * 0 1 * 20 B * 40 4 * 60 D * 80 E */ } private static void Job_TaskProgressUpdated(object sender, TaskProgressEventArgs e) { Console.WriteLine("{0} {1}", e.Description.Progress, e.Description.AdditionalInformation); } [Serializable] public class ProgressTask : Task { public override void Execute() { this.SetProgress(0, 1); System.Threading.Thread.Sleep(1000); this.SetProgress(20, "B"); System.Threading.Thread.Sleep(1000); this.SetProgress(40, 4); System.Threading.Thread.Sleep(1000); this.SetProgress(60, "D"); System.Threading.Thread.Sleep(1000); this.SetProgress(80, "E"); System.Threading.Thread.Sleep(1000); } } } }
STK Parallel Computing Server 2.9 API for .NET