Dynamically control the resources allocated to task

using System;
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();
                Task task = new YieldResourceDemo();
                Job job = scheduler.CreateJob();
                job.AddTask(task);
                job.Submit();
                job.WaitUntilDone();

                Console.WriteLine(task.StandardOutput);
            }

            /*
             * The output of the application should resemble:
             * Initial: Consuming 1 Cores
             * After YieldResource: Consuming 0 Cores
             * After ReserveResource: Consuming 1 Cores
             */
        }

        [Serializable]
        public class YieldResourceDemo : Task
        {
            public override void Execute()
            {
                IJobSchedulerContext jobSchedulerContext = this.GetProperty<IJobSchedulerContext>(TaskProperties.JobSchedulerContext);

                // You can pass 0 to query that amount the task is currently consuming.
                long currentConsumption = jobSchedulerContext.YieldResource(ConsumableResources.Cores, 0);
                Console.WriteLine("Initial: Consuming {0} Cores", currentConsumption);

                // Let's yield the resource to the global resource poll
                currentConsumption = jobSchedulerContext.YieldResource(ConsumableResources.Cores, 1);
                Console.WriteLine("After YieldResource: Consuming {0} Cores", currentConsumption);

                // We can also dynmically increase our resource consumption.
                currentConsumption = jobSchedulerContext.ReserveResource(ConsumableResources.Cores, 1);
                Console.WriteLine("After ReserveResource: Consuming {0} Cores", currentConsumption);
            }
        }
    }
}