黑马程序员技术交流社区
标题:
如何应用多线程啊
[打印本页]
作者:
何荣智
时间:
2011-11-6 22:13
标题:
如何应用多线程啊
大家指教啊!!
作者:
何荣智
时间:
2011-11-6 22:24
C#程序默认情况下具有一个线程,代码也都是从上至下逐行执行的。 不过,可以创建辅助线程,以便与主线程一起并行执行代码。 这些线程通常称为“辅助线程”。.NET Framework System.Threading 命名空间使线程更易于使用。
创建线程
--------------------------------------------------------------------------------
创建新的 Thread 对象时,将创建新的托管线程。 Thread 类具有接受一个 ThreadStart 委托或 ParameterizedThreadStart 委托的构造函数:该委托包装调用 Start 方法时由新线程调用的方法。 多次调用 Start 将引发 ThreadStateException。
System.Threading.Thread newThread = new System.Threading.Thread(AMethod);
若要开始执行新线程,可使用 Start 方法,
若要停止执行线程,可使用 Abort 方法,
除启动和停止线程之外,还可以通过调用 Sleep方法,当前线程立即阻止,阻止时间的长度等于传递给 Thread.Sleep 的毫秒数 ,
Suspend ()方法挂起线程、使用 Resume 方法继续挂起的线程,(挂起和继续已过时),
以及使用 Abort 方法销毁线程。
1 public static void ThreadProc() 2 { 3 for (int i = 0; true; i++) 4 { 5 Console.WriteLine("ThreadProc: {0}", i); 6 Thread.Sleep(0); 7 } 8 } 9 10 11 static void Main(string[] args)12 {13 //主线程开始14 Console.WriteLine("Main thread: Start");15 16 Thread t = new Thread(new ThreadStart(ThreadProc)); 17 18 //辅助线程开始19 t.Start();20 21 //暂停5毫秒22 Thread.Sleep(5);23 for (int i = 0; i < 4; i++)24 {25 Console.WriteLine("Main thread: Do some work.{0}",i);26 Thread.Sleep(0);27 }28 //辅助线程结束29 t.Abort();30 Console.ReadLine();ThreadProc()方法看起来是一个死循环,但是当调用t.Abort()方法就会停止辅助线程,从而结束!
简单的传参和回调
1 public class Number 2 { 3 private int one; 4 private int two; 5 6 7 private CallbackCalculate callback; 8 9 public Number(int numberOne,int numberTwo,CallbackCalculate callbackDelegate)10 {11 one = numberOne;12 two = numberTwo;13 callback = callbackDelegate;14 }15 16 public void Calculate()17 {18 Thread.Sleep(10);19 Console.WriteLine(((char)one).ToString()+((char)two).ToString());20 if (callback!=null)21 {22 callback(one + two);23 }24 }25 }26 27 //回调委托28 public delegate void CallbackCalculate(int result); 29 30 31 class Program32 {33 static void Main(string[] args)34 {35 Number number = new Number(65, 97, new CallbackCalculate(Callback));36 37 Thread t = new Thread(new ThreadStart(number.Calculate));38 39 //表示当前线程是否是后天线程40 t.IsBackground = false;41 42 //当前线程优先级43 t.Priority = ThreadPriority.Highest;44 45 t.Start();46 Console.WriteLine("主线程做一些工作,然后等待");47 //使当前线程一直等到另一线程完成48 t.Join();49 Console.WriteLine("独立的任务已经完成,主线程结束");50 Console.ReadLine();51 }52 53 private static void Callback(int result)54 {55 Console.WriteLine("Main Number:{0}",result);56 }57 }
需要注意的是主线程和创建的辅助线程都默认是前台线程Thread.IsBackground = false;后台线程与前台线程类似,但后台线程不阻止进程停止。 一旦某个进程的所有前台线程都停止,公共语言运行时就会对仍处于活动状态的后台线程调用 Abort 方法,从而结束该进程。
作者:
何荣智
时间:
2011-11-6 22:24
C#程序默认情况下具有一个线程,代码也都是从上至下逐行执行的。 不过,可以创建辅助线程,以便与主线程一起并行执行代码。 这些线程通常称为“辅助线程”。.NET Framework System.Threading 命名空间使线程更易于使用。
创建线程
--------------------------------------------------------------------------------
创建新的 Thread 对象时,将创建新的托管线程。 Thread 类具有接受一个 ThreadStart 委托或 ParameterizedThreadStart 委托的构造函数:该委托包装调用 Start 方法时由新线程调用的方法。 多次调用 Start 将引发 ThreadStateException。
System.Threading.Thread newThread = new System.Threading.Thread(AMethod);
若要开始执行新线程,可使用 Start 方法,
若要停止执行线程,可使用 Abort 方法,
除启动和停止线程之外,还可以通过调用 Sleep方法,当前线程立即阻止,阻止时间的长度等于传递给 Thread.Sleep 的毫秒数 ,
Suspend ()方法挂起线程、使用 Resume 方法继续挂起的线程,(挂起和继续已过时),
以及使用 Abort 方法销毁线程。
1 public static void ThreadProc() 2 { 3 for (int i = 0; true; i++) 4 { 5 Console.WriteLine("ThreadProc: {0}", i); 6 Thread.Sleep(0); 7 } 8 } 9 10 11 static void Main(string[] args)12 {13 //主线程开始14 Console.WriteLine("Main thread: Start");15 16 Thread t = new Thread(new ThreadStart(ThreadProc)); 17 18 //辅助线程开始19 t.Start();20 21 //暂停5毫秒22 Thread.Sleep(5);23 for (int i = 0; i < 4; i++)24 {25 Console.WriteLine("Main thread: Do some work.{0}",i);26 Thread.Sleep(0);27 }28 //辅助线程结束29 t.Abort();30 Console.ReadLine();ThreadProc()方法看起来是一个死循环,但是当调用t.Abort()方法就会停止辅助线程,从而结束!
简单的传参和回调
1 public class Number 2 { 3 private int one; 4 private int two; 5 6 7 private CallbackCalculate callback; 8 9 public Number(int numberOne,int numberTwo,CallbackCalculate callbackDelegate)10 {11 one = numberOne;12 two = numberTwo;13 callback = callbackDelegate;14 }15 16 public void Calculate()17 {18 Thread.Sleep(10);19 Console.WriteLine(((char)one).ToString()+((char)two).ToString());20 if (callback!=null)21 {22 callback(one + two);23 }24 }25 }26 27 //回调委托28 public delegate void CallbackCalculate(int result); 29 30 31 class Program32 {33 static void Main(string[] args)34 {35 Number number = new Number(65, 97, new CallbackCalculate(Callback));36 37 Thread t = new Thread(new ThreadStart(number.Calculate));38 39 //表示当前线程是否是后天线程40 t.IsBackground = false;41 42 //当前线程优先级43 t.Priority = ThreadPriority.Highest;44 45 t.Start();46 Console.WriteLine("主线程做一些工作,然后等待");47 //使当前线程一直等到另一线程完成48 t.Join();49 Console.WriteLine("独立的任务已经完成,主线程结束");50 Console.ReadLine();51 }52 53 private static void Callback(int result)54 {55 Console.WriteLine("Main Number:{0}",result);56 }57 }
需要注意的是主线程和创建的辅助线程都默认是前台线程Thread.IsBackground = false;后台线程与前台线程类似,但后台线程不阻止进程停止。 一旦某个进程的所有前台线程都停止,公共语言运行时就会对仍处于活动状态的后台线程调用 Abort 方法,从而结束该进程。
作者:
宋天琪
时间:
2011-11-7 17:16
第一:
一般来说,直接在子线程中对窗体上的控件操作是会出现异常,这是由于子线程和运行窗体的线程是不
同的空间,因此想要在子线程来操作窗体上的控件,是不可能简单的通过控件对象名来操作,但不是说不能
进行操作,微软提供了Invoke的方法,其作用就是让子线程告诉窗体线程来完成相应的控件操作。
现在用一个用线程控制的进程条来说明,大致的步骤如下:
1. 创建Invoke函数,大致如下:
/// <summary>
/// Delegate function to be invoked by main thread
/// </summary>
private void InvokeFun()
{
if( prgBar.Value < 100 )
prgBar.Value = prgBar.Value + 1;
}
2. 子线程入口函数:
/// <summary>
/// Thread function interface
/// </summary>
private void ThreadFun()
{
//Create invoke method by specific function
MethodInvoker mi = new MethodInvoker( this.InvokeFun );
for( int i = 0; i < 100; i++ )
{
this.BeginInvoke( mi );
Thread.Sleep( 100 );
}
}
3. 创建子线程:
Thread thdProcess = new Thread( new ThreadStart( ThreadFun ) );
thdProcess.Start();
备注:
using System.Threading;
private System.Windows.Forms.ProgressBar prgBar;
Control.CheckForIllegalCrossThreadCalls = false; 线程开始的时候加这么一句,OK,看不到错误了~
啥都能用了~
第二:
用委托,在05里,每个控件都有个InvokeRequired的属性~,判断一下是不是true,是的话进行Invoke操作
的,完事了~
//建立个委托
private delegate string returnStrDelegate();
//搞个最简单滴取值滴方法~
private string returnSchool()
{
return CB_School.SelectedValue.ToString();
}
//判断一下是不是该用Invoke滴~,不是就直接返回~
private string returnCB(returnStrDelegate myDelegate)
{
if (this.InvokeRequired)
{
return (string)this.Invoke(myDelegate);
}
else
{
return myDelegate();
}
}
//别的线程里的调用哇~
string _school = returnCB(returnSchool);
大概就是这样的,貌似有听说最好别用第一种方法,具体为啥我也不知道~反正我一直都用委托的,也不是
很麻烦~
麻烦知道的更清楚的人给说一声为什么,谢谢了~
在多线程编程中,我们经常要在工作线程中去更新界面显示,而在多线程中直接调用界面控件的方法是错误
的做法,Invoke 和 BeginInvoke 就是为了解决这个问题而出现的,使你在多线程中安全的更新界面显示。
正确的做法是将工作线程中涉及更新界面的代码封装为一个方法,通过 Invoke 或者 BeginInvoke 去调用,
两者的区别就是一个导致工作线程等待,而另外一个则不会。
而所谓的“一面响应操作,一面添加节点”永远只能是相对的,使 UI 线程的负担不至于太大而已,因为界
面的正确更新始终要通过 UI 线程去做,我们要做的事情是在工作线程中包揽大部分的运算,而将对纯粹的
界面更新放到 UI 线程中去做,这样也就达到了减轻 UI 线程负担的目的了。
再举个简单例子说明下使用方法,比如你在启动一个线程,在线程的方法中想更新窗体中的一个TextBox..
using System.Threading;
public delegate void MyInvoke(string str);
private void btnStartThread_Click(object sender, EventArgs e)
{
Thread thread = new Thread(new ThreadStart(DoWord));
thread.Start();
}
public void DoWord()
{
MyInvoke mi = new MyInvoke(SetTxt);
BeginInvoke(mi,new object[]{"abc"});
}
public void SetTxt(string str)
{
txtReceive.Text += str + System.Environment.NewLine;
}
看看我的代码托管:
public delegate void MyInvoke(string str);
public void SetTxt(string str)
{
m_receive_text.Text += str;
}
public void showMessage()
{
MyInvoke mi = new MyInvoke(SetTxt);
while (true)
{
if (serial.m_responses.Count != 0)
{
BeginInvoke(mi, new object[] { serial.m_responses[0] });
serial.m_responses.RemoveAt(0);
}
else
{
System.Threading.Thread.Sleep(200); // 等待2个tick
}
}
}
方法1 例子
//更新ListBox信息
public delegate void UpdateListBoxCallback();
//更新用户列表
private void UpdateClientListControl()
{
if (InvokeRequired)
{
listBoxClientList.BeginInvoke(new UpdateListBoxCallback(UpdateClientList), null);
}
else
{
//创建该控件的主线程直接更新信息列表
UpdateClientList();
}
}
//更新代码在这里
public void UpdateClientList()
{
listBoxClientList.Items.Clear();
for (int index = 0; index < WorkerSocketList.Count; index++)
{
string clientKey = Convert.ToString(index + 1);
Socket workerSocket = (Socket)WorkerSocketList[index];
if (workerSocket != null)
{
//将连接着服务器的客户添加到客户列表中
if (workerSocket.Connected)
{
listBoxClientList.Items.Add(clientKey);
}
}
}
}
方法2 例子
public delegate void ShowMacInList(ListBox listBox, object obj);
public event ShowMacInList ShowAllRresultInList;
//链接
this.ShowAllRresultInList += new ShowMacInList(RWOL_ShowAllRresultInList);
//
void RWOL_ShowAllRresultInList(ListBox listBox, object obj)
{
try
{
this.BeginInvoke(new ShowMacInList(ShowResult),
new object[] { listBox, obj });
}
catch
{
}
参考:CSDN
作者:
yy312232557
时间:
2011-11-7 23:10
多线程 是个很深奥的问题,一直不怎么懂,
但是我知道 silverlight 开发中, 因为市场和webservice 和WCF 打交道进行异步数据处理
这时会有很多地方通过多线程,
因为这个时候通过这种非 ADO.NET 方式去获取数据,等,
在数据量非常大的时候,我们就需要开多线程,
单独开一个线程进行数据处理,另外在开一个线程进行UI绘制
大概的思路就是
Thread th = new Thread(methodName);
具体的,楼主可以查阅一下网上的相关资料
欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)
黑马程序员IT技术论坛 X3.2