Technology Corner

Home » Parallel Programming » Task Parallelism: Parallel programming – II

Task Parallelism: Parallel programming – II

Enter your email address to follow this blog and receive notifications of new posts by email.

Join 80 other followers

Twitter updates

Archives

RSS InfoQ Feeds

  • How Google Develops New Managers
    Alex Langshur, host of Google Partners Podcasts, has organized the podcast Google HR secrets: identifying & developing great managers, interviewing Sarah Calderon, People Development at Google, on how Google selects, trains, and develops their managers. By Abel Avram
  • Presentation: Cognitive Services, Next Step in Creating Our Robot Overlords
    Harold Pulcher discusses Cognitive Services, how to get started using them, and how to incorporate speech, image, and facial recognition into an application. By Harold Pulcher
  • Presentation: Control Flow Integrity Using Hardware Counters
    Jamie Butler and Cody Pierce discuss a new system for early detection and prevention of unknown exploits. Their system uses Performance Monitoring Unit hardware to enforce coarse-grained Control Flow Integrity (CFI). They intend to prove that their approach is effective and suitable for practical use, while staying resistant to bypass. By Jamie Butler
  • JetBrains Launches GoLand Go IDE
    JetBrains has moved its Go IDE from its early access programme to market. Now branded as GoLand, the IDE extends the IntelliJ platform making its core functionality specific to Go. This follows suit with their other language-specific tools such as PyCharm for Python and RubyMine for Ruby. By Andrew Morgan
  • Panel on the Future of AI
    An SF QCon panel on the future of AI explored some issues facing machine learning today. The areas explored: critical issues facing AI right now, how has technology changed the way people are hired, how non-leading edge companies make the best use of current technologies, what the role of humans in relation to AI is, and exciting new breakthroughs on the imm […]
  • Microsoft Updates Cosmos DB with Cassandra Support and Provides Better Availability Guarantees
    Last month at Microsoft Connect 2017, Azure Cosmos DB received several new updates, including support for using the Cassandra NoSQL database API and increased guarantees for availability. With the Cassandra NoSQL database API, customers can run operations inside Cosmos DB on a data model. The availability guarantee moves from 99.99 percent to 99.999 percent. […]
  • Article: Approximate Computing on WSO2: Explaining Approximation Algorithms in an Applied Setting
    In this article, we describe an example real world application of API monitoring which gets benefit by using approximate stream processing. We developed the application on top of WSO2 Stream Processor as Siddhi extension. Siddhi is the complex event processing library which acts as the event processing engine of WSO2 Stream Processor. By Chamod Samarajeewa
  • Rust in Visual Studio and VS Code
    Daniel Griffen has released a preview version of a Rust language service for Visual Studio. This plugin requires Visual Studio 2017 Preview, an experimental release stream for testing new VS features. By Jonathan Allen
  • Article: Key Takeaway Points and Lessons Learned from QCon San Francisco 2017
    The eleventh annual QCon San Francisco was the biggest yet, bringing together over 1,800 team leads, architects, project managers, and engineering directors. By Abel Avram
  • Article: Q&A With Eberhard Wolff On the Book “A Practical Guide to Continuous Delivery”
    Eberhard Wolff speaks with InfoQ about his work "Continuous Delivery: A Practical Guide", where we detail some of the major concepts behind successful CD adoption and the ripple-effect it can have on developer productivity and quality of service. By Dylan Raithel

 

Please read Begin with Parallel programming in Dotnet 4.0 article if you have not read.

Task Parallelism

This is strategy to run independent task in parallel way. It focuses on distributing execution process (threads) across different parallel computing nodes.Task parallelism emphasizes the distributed (parallelized) nature of the processing (i.e. threads), as opposed to the data parallelism. Most real programs fall somewhere on a continuum between Task parallelism and Data parallelism. Workflow of task parallelism is below:

 

image

Dot Net Framework provides Task Parallel Library (TPL)  to achieve Task Parallelism. This library provides two primary benefits:

  1. More Efficient and more scalable use of system resources.
  2. More programmatic control than is possible with a thread or work item.

Behind the scenes tasks are queued in ThreadPool, which has been enhanced with algorithms in .Net 4.0 that determine and adjust to the number of threads that maximizes throughput. This makes tasks relatively lightweight, and you can create many of them to enable fine-grained parallelism. To complement this, widely-known work-stealing algorithms are employed to provide load-balancing.

This library provides more features to control tasks like: cancellation, continuation, waiting, robust exception handling, scheduling etc.

The classes for TaskParallelism are defined in System.Threading.Tasks:

Class Purpose
Task For running unit of work concurrently.
Task<Result> For managing unit of work with return value
TaskFactory Factory Class to create Task class Instance.
TaskFactory<TResult> Factory Class to create Task class Instance and return value.
TaskScheduler for scheduling tasks.
TaskCompletionSource For manually controlling a
task’s workflow

How to Create and execute Tasks

Task Creation and Execution can be done by two ways: Implicit and Explicit.

Create and Execute Task Implicitly

Parallel.Invoke method helps to to run unit of work in parallel. you can just pass any number of Action delegates as parameters. The no. of tasks created by Invoke method is not necessarily equal to Action delegates provided because this method automatically does some optimization specially in this case.

Source Code

        private static void Run2()
        {
            Thread.Sleep(1000);
            Console.WriteLine("Run2: My Thread Id {0}", Thread.CurrentThread.ManagedThreadId);
        }

        private static void Run1()
        {
            Thread.Sleep(1000);
            Console.WriteLine("Run1: My Thread Id {0}", Thread.CurrentThread.ManagedThreadId);
        }

        static void Main(string[] args)
        {
            //Create and Run task implicitly
            Parallel.Invoke(() => Run1(), () => Run2());
            Console.ReadLine();
        }

Output

Run2: My Thread Id 11

Run1: My Thread Id 10

This approach of creating task does not give greater control over task execution, scheduling etc. Better approach is to create task by TaskFactory class.

Create and Execute Task Explicitly

You can create task by creating instance of task class and pass delegate which encapsulate the code that task will execute. These delegate can be anonyms, Action delegate, lambda express and method name etc.

Example of creating tasks:

Source Code:

        private static void Run2()
        {
            Thread.Sleep(1000);
            Console.WriteLine("Run2: My Thread Id {0}", Thread.CurrentThread.ManagedThreadId);

        }

        private static void Run1()
        {
            Thread.Sleep(1000);
            Console.WriteLine("Run1: My Thread Id {0}", Thread.CurrentThread.ManagedThreadId);

        }

        static void Main(string[] args)
        {
            // Create a task and supply a user delegate by using a lambda expression.
            // use an Action delegate and a named method
            Task task1 = new Task(new Action(Run1));

            // use a anonymous delegate
            Task task2 = new Task(delegate
                        {
                            Run1();
                        });

            // use a lambda expression and a named method
            Task task3 = new Task(() => Run1());
            // use a lambda expression and an anonymous method
            Task task4 = new Task(() =>
            {

                Run1();
            });

            task1.Start();
            task2.Start();
            task3.Start();
            task4.Start();
            Console.ReadLine();
        }

Output

Run1: My Thread Id 13

Run1: My Thread Id 12

Run1: My Thread Id 11

Run1: My Thread Id 14

If you don’t want to create and starting of task separated then you can use TaskFactory class. Task exposes “Factory” property which is instance of TaskFactory class.

Task task5= Task.Factory.StartNew(()=> {Run1();});

Task with Return Values

To get value from when task completes it execution, you can use generic version of Task class.

 public static void Main(string[] args)
        {
            //This will return string result
            Task task = Task.Factory.StartNew(() => ReturnString());
            Console.WriteLine(task.Result);// Wait for task to finish and fetch result.
            Console.ReadLine();
            
        }

        private static string ReturnString()
        {
            return "Neeraj";
        }

Task State

If you are running multiple tasks same time and you want to track progress of each task then using "State" object is better approach.

 
	public static void Main(string[] args)
        {
            //This will return string result
            for (int i = 0; i < 5; i++)
            {
                Task task = Task.Factory.StartNew(state => ReturnString(), i.ToString());
                //Show progress of task
                Console.WriteLine("Progress of this task {0}: {1}", i, task.AsyncState.ToString());
            }
            
            Console.ReadLine();

        }

        private static void  ReturnString()
        {
            //DO something here

           // Console.WriteLine("hello");
        }

Output

Progress of this task 0: 0

Progress of this task 1: 1

Progress of this task 2: 2

Progress of this task 3: 3

Progress of this task 4: 4

In Next blog, I’ll explain TaskCreationOptions,Waiting,Cancellation tasks etc.

Please keep giving your valuable feedbacks.

Advertisements

Leave a Reply

Fill in your details below or click an icon to log in:

WordPress.com Logo

You are commenting using your WordPress.com account. Log Out / Change )

Twitter picture

You are commenting using your Twitter account. Log Out / Change )

Facebook photo

You are commenting using your Facebook account. Log Out / Change )

Google+ photo

You are commenting using your Google+ account. Log Out / Change )

Connecting to %s

Blogs I Follow

%d bloggers like this: