Thread中带参方法无法使用之解决方案
2006-12-20 15:06
357 查看
using System;
using System.Collections.Generic;
using System.Collections;
using System.Threading;
namespace ThreadHelperLib
{
public class ThreadHelper
{
public ThreadHelper()
{
}
~ThreadHelper() { }
#region 私有变量
/// <summary>
/// 当前线程
/// </summary>
private Thread thrWork = null;
/// <summary>
/// 参数集合
/// </summary>
private List<object> objParams = new List<object>();
/// <summary>
/// 方法
/// </summary>
private Delegate Method = null ;
/// <summary>
/// 线程结束标识
/// </summary>
private bool overFlag = false;
private string Error = string.Empty;
#endregion
#region 公共方法
/// <summary>
/// 设置参数
/// </summary>
/// <param name="o"></param>
public void SetParams(object o)
{
objParams.Add(o);
}
/// <summary>
/// 设置方法
/// </summary>
/// <param name="pMethod"></param>
public void SetMethod(Delegate pMethod)
{
Method = pMethod;
}
public bool StartThread()
{
try
{
ThreadStart myThreadStart = new ThreadStart(this.ThreadProc);
thrWork = new Thread(myThreadStart);
thrWork.Start();
return true;
}
catch (ThreadStartException e)
{
Error = e.ToString();
thrWork.Abort();
return false;
}
}
public void EndStart()
{
if (this.overFlag)
{
this.thrWork.Abort();
}
}
/// <summary>
/// 错误消息
/// </summary>
/// <returns></returns>
public string outError()
{
return this.Error;
}
#endregion
#region 私有方法
private void ThreadProc()
{
try
{
System.Collections.IEnumerator m_Enum = objParams.GetEnumerator();
while (m_Enum.MoveNext())
{
Method.DynamicInvoke(m_Enum.Current);
}
}
catch (ThreadStateException err)
{
this.Error = err.ToString();
}
finally
{
this.overFlag = true;
}
}
#endregion
}
}
using System;
using System.Collections.Generic;
using System.Text;
using ThreadHelperLib;
namespace helloWorld
{
class Program
{
private delegate void TestCall(string str);
static void Main()
{
string state = "123";
for (int i = 0; i < 3000; i++)
{
ThreadHelper thr = new ThreadHelper();
thr.SetMethod(new TestCall(test));
thr.SetParams(i.ToString());
thr.StartThread();
thr.EndStart();
}
Console.ReadLine();
}
private static void test(string state)
{
Console.WriteLine(state);
}
static void c_OnTestHandler()
{
Console.WriteLine("sadfasdfsadf");
}
}
}
using System.Collections.Generic;
using System.Collections;
using System.Threading;
namespace ThreadHelperLib
{
public class ThreadHelper
{
public ThreadHelper()
{
}
~ThreadHelper() { }
#region 私有变量
/// <summary>
/// 当前线程
/// </summary>
private Thread thrWork = null;
/// <summary>
/// 参数集合
/// </summary>
private List<object> objParams = new List<object>();
/// <summary>
/// 方法
/// </summary>
private Delegate Method = null ;
/// <summary>
/// 线程结束标识
/// </summary>
private bool overFlag = false;
private string Error = string.Empty;
#endregion
#region 公共方法
/// <summary>
/// 设置参数
/// </summary>
/// <param name="o"></param>
public void SetParams(object o)
{
objParams.Add(o);
}
/// <summary>
/// 设置方法
/// </summary>
/// <param name="pMethod"></param>
public void SetMethod(Delegate pMethod)
{
Method = pMethod;
}
public bool StartThread()
{
try
{
ThreadStart myThreadStart = new ThreadStart(this.ThreadProc);
thrWork = new Thread(myThreadStart);
thrWork.Start();
return true;
}
catch (ThreadStartException e)
{
Error = e.ToString();
thrWork.Abort();
return false;
}
}
public void EndStart()
{
if (this.overFlag)
{
this.thrWork.Abort();
}
}
/// <summary>
/// 错误消息
/// </summary>
/// <returns></returns>
public string outError()
{
return this.Error;
}
#endregion
#region 私有方法
private void ThreadProc()
{
try
{
System.Collections.IEnumerator m_Enum = objParams.GetEnumerator();
while (m_Enum.MoveNext())
{
Method.DynamicInvoke(m_Enum.Current);
}
}
catch (ThreadStateException err)
{
this.Error = err.ToString();
}
finally
{
this.overFlag = true;
}
}
#endregion
}
}
using System;
using System.Collections.Generic;
using System.Text;
using ThreadHelperLib;
namespace helloWorld
{
class Program
{
private delegate void TestCall(string str);
static void Main()
{
string state = "123";
for (int i = 0; i < 3000; i++)
{
ThreadHelper thr = new ThreadHelper();
thr.SetMethod(new TestCall(test));
thr.SetParams(i.ToString());
thr.StartThread();
thr.EndStart();
}
Console.ReadLine();
}
private static void test(string state)
{
Console.WriteLine(state);
}
static void c_OnTestHandler()
{
Console.WriteLine("sadfasdfsadf");
}
}
}
相关文章推荐
- jz2440 win7 64位系统mini usb驱动无法兼容的解决方案,及其使用u-boot烧写Nand-flash的方法
- 使用runOnUiThread解决Handler无法调用含用子线程方法的问题
- CRectTracker类的使用方法及其静态库下CRectTracker无法显示鼠标光标解决方案
- CRectTracker类的使用方法及其静态库下CRectTracker无法显示鼠标光标解决方案
- CRectTracker类的使用方法及其静态库下CRectTracker无法显示鼠标光标解决方案
- CRectTracker类的使用方法及其静态库下CRectTracker无法显示鼠标光标解决方案(转)
- 工作中的问题解决 -- (win2003 asp.net) Session和带页面回传的方法无法正常使用解决方案
- CRectTracker类的使用方法及其静态库下CRectTracker无法显示鼠标光标解决方案
- 【iOS发展-53】实例探究:scrollView使用方法和解决方案无法滚动核心
- Win10系统下无线网卡无法使用问题的解决方法
- AWAY3D4BETA版在ipad移动设备上无法使用手指触发某一个3d对象的解决方案
- Win8.1系统切换使用Administrator提示“无法使用内置管理员账户打开程序”的解决方法
- 解决vue-cli中stylus无法使用的问题方法
- 【Vegas原创】使用GreenAMP时,提示“无法载入mysql扩展”解决方法
- Ubuntu安装后root 用户无法使用的解决方法
- Linux下U盘无法使用的解决方案
- 用流的方法解决“文件正由另一进程使用,因此该进程无法访问该文件” 的问题 FileStream
- Vista上无法使用WCF的处理方法
- 关于“因为数据库正在使用,所以无法获得对数据库的独占访问权”的最终解决方案
- 各大网站无法使用右键的原因及解决方法