How to transfer data between multithreading and UI

Question

2.50/5 (2 votes)

See more:

In UI i calls ProcessFiles method in Backgroundworker class.In this processfiles method i have created threads with monitorque method which is in worker class.
Now i want to pass data to UI when there may be an multiple errors for each thread.
How should i achieve this? I am placing code below.I tried to create delegate but how should i call this delegate method in another worker class?so that i will update data !thanks in advance..

C#

 public partial class Form1 : Form
    {
 private void Bworker_DoWork(object sender, DoWorkEventArgs e)
        {
            ProcessFiles();
            
        }


private void  processFiles()
{
	    numberOfThreads = lstfiles.Items.Count;
            Thread[] threads = new Thread[numberOfThreads];
            Worker worker = new Worker();
            for (int index = 0; index < numberOfThreads; index++)
            {
                threads[index] = new Thread(worker.MonitorQueue);
                threads[index].Start();
            }
            int i=0;
            foreach (string fName in lstfiles.Items)
            {
                worker.DocumentQueue.EnqueueItem(fName);
                temp.Add(fName);                                 
            }
}
}
------------------
public class Worker
	{
        static string csvOutputFilePath =AppDomain.CurrentDomain.BaseDirectory + "\\output\\";
		private DocumentQueue documentQueue;        
		public DocumentQueue DocumentQueue
		{
			get
			{
				return documentQueue;
			}
		}

		public void MonitorQueue()
		{
			try
			{
				while (true)
				{
					object document = documentQueue.ConsumeItem();
					if ((document == null))
					{
						//enqueue another null to terminate the next thread if there is one
						documentQueue.EnqueueItem(null);
						break;
					}
					else
					{
						ProcessDocument(document.ToString());
					}
				}
			}
			catch (Exception exception)
			{
				System.Console.WriteLine(exception.Message);
			}
		}

		private void ProcessDocument(string document)
		{
			}
}

Posted 10-Dec-15 21:40pm

sp_suresh

Add a Solution

Comments

Sergey Alexandrovich Kryukov 11-Dec-15 15:36pm

It depends on what you want to do with the data. As you did not solve this problem so far, it's not shown where you try to pass data. One of the approach is to pass not data, but delegate instance using Control.Invoke or Control.BeginInvoke. It depends on what you want to achieve.

Your "how should i call this delegate method in another worker class" is quite unclear. What is "between"? Are you asking about passing data to a non-UI thread from UI thread, or visa versa?

—SA

1 solution

Add a Solution

Add your solution here

Treat my content as plain text, not as HTML

Preview 0

…

Existing Members

Sign in to your account

...or Join us

Download, Vote, Comment, Publish.

Your Email
Password
Forgot your password?

Your Email
This email is in use. Do you need your password?
Optional Password

I have read and agree to the Terms of Service and Privacy Policy
Please subscribe me to the CodeProject newsletters

When answering a question please:

Read the question carefully.
Understand that English isn't everyone's first language so be lenient of bad spelling and grammar.
If a question is poorly phrased then either ask for clarification, ignore it, or edit the question and fix the problem. Insults are not welcome.
Don't tell someone to read the manual. Chances are they have and don't get it. Provide an answer or move on to the next question.

Let's work to help developers, not make them feel stupid.

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

User 10668410 · Answer 1 · 2015-12-11T16:41:00

You haven't really given enough information but at a glance of your implementation i would probably just do one of these and not even bother with managing the threads myself.

C#

void DoStuff()
{
    // Has been called from a "wrong" thread?
    if (InvokeRequired)
    {
        // Dispatch to correct thread, use BeginInvoke if you don't need
        // caller thread until operation completes
        Invoke(new MethodInvoker(DoStuff));
    }
    else {
        // Do things
    }
}


void DoStuff()
{
    if (InvokeRequired)
    {
        Invoke(new MethodInvoker(delegate
        {

        // Do things

        }));
    }
}