主程序从文件读取数据,每行开一个线程去处理,线程数nThreads不能大于nMaxThreads,每个线程完成工作后,都要向DataGridView添加一行结果,用委托实现,结果是卡死.调试时,每个线程委托根本执行不到dataGridViewX1.Rows.Add(dgvr)这里来.请高手们指教啊!看哪里有问题,或是有其它好方法实现也行啊!private int nMaxThreads, nThreads;
public delegate void CB_SetDataGridViewInfo(DataGridViewRow dgvr);
public void Deg_SetDataGridViewInfo(DataGridViewRow dgvr)//委托的方法
{
if (this.dataGridViewX1.InvokeRequired)
{
CB_SetDataGridViewInfo cs = new CB_SetDataGridViewInfo(Deg_SetDataGridViewInfo);
this.BeginInvoke(cs, new object[] { dgvr });
}
else
{
dataGridViewX1.Rows.Add(dgvr);
dataGridViewX1.FirstDisplayedScrollingRowIndex = dataGridViewX1.Rows.Count;
}
}
private void Thd_Start(object objPara)//线程
{
do something.........//主要工作 DataGridViewRow dgvr = new DataGridViewRow();
dgvr.CreateCells(dataGridViewX1);
for (int i = 0; i < 10; i++)
{
dgvr.Cells[i].Value = i;//这里是工作后的结果,用i临时代替一下
}
lock(this)
{
nThreads -= 1;//线程数减一
}
Deg_SetDataGridViewInfo(dgvr);// 托管调用
}
private void btxStart_Click(object sender, EventArgs e)
{
if (tbxOpenFile.Text == null)
{
MessageBox.Show("请选择数据文件!");
return;
}
string[] strLines = File.ReadAllLines(tbxOpenFile.Text, Encoding.Default);
int nRows = strLines.Length;//总行数
nMaxThreads = (int)nUDThread.Value;
nThreads = 0;
int nNow = 0;
do
{
if (nThreads < nMaxThreads)//比较线程数有没有到最大限制
{
int nT = nMaxThreads - nThreads;
for (int i = 0; i < nT; i++)
{
string strLine = strLines[nNow + i];
Thread StartVerifyThread = new Thread(new ParameterizedThreadStart(Thd_StartVerify));
StartVerifyThread.IsBackground = true;
StartVerifyThread.Start(strLine);
} lock (this)
{
nNow += nT;
nThreads += nT;
}
}
} while (nNow != nRows);//处理完所有数据行
}
public delegate void CB_SetDataGridViewInfo(DataGridViewRow dgvr);
public void Deg_SetDataGridViewInfo(DataGridViewRow dgvr)//委托的方法
{
if (this.dataGridViewX1.InvokeRequired)
{
CB_SetDataGridViewInfo cs = new CB_SetDataGridViewInfo(Deg_SetDataGridViewInfo);
this.BeginInvoke(cs, new object[] { dgvr });
}
else
{
dataGridViewX1.Rows.Add(dgvr);
dataGridViewX1.FirstDisplayedScrollingRowIndex = dataGridViewX1.Rows.Count;
}
}
private void Thd_Start(object objPara)//线程
{
do something.........//主要工作 DataGridViewRow dgvr = new DataGridViewRow();
dgvr.CreateCells(dataGridViewX1);
for (int i = 0; i < 10; i++)
{
dgvr.Cells[i].Value = i;//这里是工作后的结果,用i临时代替一下
}
lock(this)
{
nThreads -= 1;//线程数减一
}
Deg_SetDataGridViewInfo(dgvr);// 托管调用
}
private void btxStart_Click(object sender, EventArgs e)
{
if (tbxOpenFile.Text == null)
{
MessageBox.Show("请选择数据文件!");
return;
}
string[] strLines = File.ReadAllLines(tbxOpenFile.Text, Encoding.Default);
int nRows = strLines.Length;//总行数
nMaxThreads = (int)nUDThread.Value;
nThreads = 0;
int nNow = 0;
do
{
if (nThreads < nMaxThreads)//比较线程数有没有到最大限制
{
int nT = nMaxThreads - nThreads;
for (int i = 0; i < nT; i++)
{
string strLine = strLines[nNow + i];
Thread StartVerifyThread = new Thread(new ParameterizedThreadStart(Thd_StartVerify));
StartVerifyThread.IsBackground = true;
StartVerifyThread.Start(strLine);
} lock (this)
{
nNow += nT;
nThreads += nT;
}
}
} while (nNow != nRows);//处理完所有数据行
}
解决方案 »
- 如何在程序中做类似在WinForm上设计时拖放控件,修改属性
- 问个问题 这样实现有没有BUG?
- 各位谁有空帮忙研究下这个程序怎么编的!
- 请问参数如果是Hashtable 或 ArrayList 时,编译通过,但是一运行就死,是什么问题呀。
- 将一个窗体复制并改名,运行时出现错误该怎么办?
- 求助加密算法.
- 一个关于c#类继承的问题不解
- DataTable中的DataColumn的Expression 明明设了好了,为什么总是null值?
- 关于导出csv文件的报错:外部表不是预期的格式。
- 求大神帮忙写一个winform最小化托盘的例子
- 检测是否运行在64位WIN7系统上
- 有无办法在自动属性上使用“NonSerialized”特性?
其二线程可以采用等待方法:线程.Join();就够用了,锁很少用到,同样可以实现.
其三不需要没行开一个线程,可以创建一个数据表,操作数据表后帮定个显示数据控件,当然也可以直接操作数据显示控件,这看个人的了.
关于Excel操作编写的一个软件设计构思案例[连载]这篇里面就采用有操作数据表和控件的方法
这里有委托和线程更容易的方法参考
不都是这样用委托的吗?
其二,我主线程是不用等待子线程的,子线程是去处理网络行为的,如每个数据行是个IP地址,子线程去ping,返回的结果显示出来.
这里写错了!应该是
private void Thd_StartVerify(object objPara)//线程
你的代码可真够繁琐曲折的。
{
nThreads -= 1;//线程数减一
}
按钮事件:读数据到数组string[],循环数组调用数据处理方法,把参数传递过去。
处理数据方法:线程处理接收回来数据,匿名委托数据赋值给控件。注意我这里说的是把线程写在方法里,而不是写在事件中。
你的那种写法我看得晕,还有你说的不用管线程处理也有问题,如果不管那么锁什么呢?如果你说不用管显示出来的数据快慢还差不多,把主次弄清楚了再设计。
21.private void 读文本(string 文件名称, string 比较内容)
{
List<string> 内容 = new List<string>(); bool 控制 = true;
if (Directory.Exists(保存路径))
{
FileInfo 文件 = new FileInfo(文件名);
if (文件.Exists)
{
using (FileStream 打开 = new FileStream(文件名, FileMode.Open))
{
using (StreamReader 读取 = new StreamReader(打开, Encoding.UTF8))
{
while (!读取.EndOfStream)
{
if (比较内容 == "") 内容.Add(读取.ReadLine());
else
if (比较内容 == 读取.ReadLine()) { 控制 = false; break; }
}
打开.Close(); if (控制) 记录文本(比较内容, 文件名称);
}
}
}
}
foreach (string 数据 in 内容) if (数据.Contains("☆")) { 补缺地址(数据); }
} 就好像这个方法一样读数据到数组,然后传递给方法去处理,再如如下方法就是使用线程和委托当然这里只是举例而已:private void 时间_Tick(object sender, EventArgs e)
{
Thread 线程 = new Thread(delegate()
{
if (秒 < 59) 秒++; else { 秒 = 0; 分++; } if (分 == 60) { 分 = 0; 时++; } if (时 == 5) 时 = 0;
this.Invoke(new Action(() =>
显示时间.Text = DateTime.Parse(时.ToString("0:") + 分.ToString("00:") + 秒.ToString("00")).ToLongTimeString()));
}); 线程.Start();
}
1.线程池自己就能管控,用不着你这么绕来绕去
2.UI是UI,数据是数据。你只对数据操作就ok,利用双向数据绑定对象,线程上下文同步对象,简单几步就ok了
那可不可以按你说的方法就是数据绑定呢?
比如说,我线程去操作数据表,数据表绑定到datagridview.线程上下文同步.试试吧!
1、如果文本文件很大,用ReadAllLines这个方法很不合适,它会一次性把文件里的内容加载到内存里,内存的消耗一定很大。
2、每个线程只处理一行文本,太浪费系统资源,要知道线程的创建和销毁也是要有开销的。
3、直接对Rows集合操作可能不是一个很好的办法,参考Windows 窗体 DataGridView 控件中的性能优化。
建议做以下修改:
1、使用1个额外的线程读取文件内容。
2、在这个线程中,使用流方式读取文本文件,如有必要可以自己派生一个TextReader类。
3、使用BindingSource。
BindingSource怎么实现?
要使用BindingSource,你得先有一个模型类,可以把文件中的列映射到类的属性里。在设计器里将DataGridView的DataSource属性指定为这个类型,设计器就会自动为你添加一个相应的BindingSource组件,而在程序里只需要往BidingSource里添加内容即可。详细的使用方便参考MSDN。
虽然你使用了多个线程,但是每个线程都访问同一个控件,由于UI线程只能允许一个线程访问,所以你一个线程在访问grid的时候,其他线程是挂起等待状态,所以还是单线程,并且比以前更慢,因为有线程切换的时间。如果要多线程,应该是多线程处理数据,处理完后在给grid的datasource赋值就行了.如果一次绑定100万条会慢,最好的方法是可以让grid一次只绑定10000条,当客户下拉滚动条的时候动态加载.
1行十几秒是什么概念?我做过一个CCProxy日志分析软件,每秒可以分析几千行,也只用了一个线程。
for (int i = 0; i < 10; i++)
{
a[i]=i;
} gridView1.DataSource = a;
DataTable dt = new DataTable();
dt.Columns.Add("Name");
for (int i = 0; i < 10; i++)
{
dt.Rows.Add(i);
}
dataGridView1.DataSource = dt;
do
{
if (nThreads < nMaxThreads)//比较线程数有没有到最大限制
{
int nT = nMaxThreads - nThreads;
for (int i = 0; i < nT; i++)
{
string strLine = strLines[nNow + i];
Thread StartVerifyThread = new Thread(new ParameterizedThreadStart(Thd_StartVerify));
StartVerifyThread.IsBackground = true;
StartVerifyThread.Start(strLine);
}
lock (this)
{
nNow += nT;
nThreads += nT;
}
}
} while (nNow != nRows);//处理完所有数据行 这样起线程方式有合理,现在改成线程数固定,每个线程处理多行数据.再用委托就没问题了!