日期:2014-05-17  浏览次数:21552 次

C# 多线程 操作Datable
现在我要用winfrom 做个多线程的程序 比如 生成10个线程 去修改 DataTable 里面的的值,Datablale有100行数据
我要用10线程去分别修改dataTable,如果10个线程中有一个线程先完毕了,然后立即去修改下一条数据比如是第11行然后再发现有线程完毕了再用线程去执行第12条(1个线程执行一行)。以此类推,一直到10线程把100行数据都修改掉。
我应该怎么做,请各位大侠请教!分不够可以加!


------解决方案--------------------
要注意别交叉操作了,最好分配每个线程一个索引范围去操作,一条条操作很容易撞车。
------解决方案--------------------
用线程池。。
------解决方案--------------------
你可以先分配一下任务,
给100条记录编个顺序号,
第一个线程处理编号为1到10的记录,
第二个线程处理编号为11到20的记录,
第三个线程处理编号为21到30的记录,
....
依此类推

当然,还有一种做法,
就是每个线程处理一条记录,就将该记录锁起来,
不给其它记录处理,处理完后再释放锁,这样就不会冲突了。
比如增加一列“状态”,状态分三个状态:“未处理、处理中、处理完毕”

一个线程处理某条记录,就标志该记录状态为“处理中”,

这样就不会冲突了,

另外还要结合事务锁来处理,
先把那条记录锁起来,很简单,开启事务,
然后先更改状态为“处理中”,因为修改了记录,就会锁住那条记录,
别的线程读不到的,但这会导致别的线程被锁住,


------解决方案--------------------
因为数据库是采用行锁的方式,
所以这个设计很讲究,

这个做法,可以先领取任务,
比如十个线程,都各自领取一条记录做任务,
给记录增加一个字段:“领取线程号”,
领取后,就更新该线程号,
然后领取任务时,只读线程号为0(就是么有领取的任务)的,
为0表示没有线程处理,没有处理就不会被锁,这样就不会导致锁定等待了,

然后处理时,就读属于自己线程号的记录,然后锁住,这样可以避免别的线程锁定

------解决方案--------------------
举个例子:

第一步:线程先读一条未处理的记录,
select min(主键) 编号 from 表 where 线程号=0

第二步:

update 表 set 线程号={自身线程号} where 编号={选出的编号} and 线程号=0

第三步:
然后筛选属于自己线程的任务:
select * from 表 where 线程号={自身线程号}

因为可能多个线程读到同一条记录,所以第二步可能更新不到记录,第三步也就读不到记录,
第三步若读不到记录,再重新从第一步开始执行:

如果第三步读到记录,就开始处理记录。
开启事务,
处理
提交/回滚.

但这个存在一个问题,
如果执行到第三步,而且能读到记录,然后处理,但处理中途,该线程死掉,
就会导致这条记录一直挂在那个线程上,再没有别的线程能够处理该记录。

所以需要设置一个延时时间,如果线程接受处理该记录,但超过指定时间,还没提交,
则需要关闭该线程,然后删除线程号,给别的线程来处理。

------解决方案--------------------
没必要这么复杂,就用lock锁定分配就行,

class XXX
{
Object rLock=new Object();

DataTable tTable=new DataTable();

int nCurRowIndex=0;

private DataRow GetRowToProcess()
{
lock(rLock)
{
if (nCurRowIndex>=tTable.Rows.Count)
{
return null;
}
DataRow rResult=tTable.Rows[nCurRowIndex];
nCurRowIndex++;
return rResult;
}
}

//这个是线程函数
void DoProcess()
{
while(true)
{
DataRow rRow=GetRowToProcess();
if (rRow==null)
{
break;
}

//...这里处理rRow,
}
}

}