Question

利用C# / NET 3.5。

目前,使用SqlDataAdapter.Fill(SqlDataAdapter.Fill(a)的2个数据表后,1个。

我愿同时把这两个数据表放在一起,同时逐个地进行。然而,Fill(Fill()方法没有同步版本,即BeginFill()将非常大!

我所尝试的一种做法是(假想):

SqlCommand1.BeginExecuteReader // 1st query, for DataTable1
SqlCommand2.BeginExecuteReader // 2nd query, for DataTable2
SqlCommand1.EndExecuteReader
SqlCommand2.EndExecuteReader
DataTable1.Load(DataReader1)
DataTable2.Load(DataReader2)

However, DataTable.Load() takes a long time:
It takes 3 seconds to do step 1 to step 4.
Step 5 then takes 22 seconds.
Step 6 takes 17 seconds.
So, combined 39 seconds for steps 5 and 6.

最终结果是,这给我带来的利益莫过于仅仅做2个SqlDataAdapter。 Fills,一个接连。我想,净结果是,整个进程只需要时间最长(或尽可能接近)的时间。

探讨所建议的办法,以最终找到一种确实是一刀切的填补数据表的方法。

或者,我只是自己管理,而滚动了2个单独的路面,每个路面都填满数据。

Answer 1

我建议,每个工人都有单独的校对。您可使用。 ThreadPool.QueueUserWorkItem。

List<AutoResetEvent> events = new List<AutoResetEvent>();

AutoResetEvent loadTable1 = new AutoResetEvent(false);
events.Add(loadTable1);
ThreadPool.QueueUserWorkItem(delegate 
{ 
     SqlCommand1.BeginExecuteReader;
     SqlCommand1.EndExecuteReader;
     DataTable1.Load(DataReader1);
     loadTable1.Set();
});

AutoResetEvent loadTable2 = new AutoResetEvent(false);
events.Add(loadTable2);
ThreadPool.QueueUserWorkItem(delegate 
{ 
     SqlCommand2.BeginExecuteReader;
     SqlCommand2.EndExecuteReader;
     DataTable2.Load(DataReader2);
     loadTable2.Set();
});

// wait until both tables have loaded.
WaitHandle.WaitAll(events.ToArray());

Answer 2

这是因为,<代码>可测量有许多物体要制造(浏览量、价值)。你们应当把一个数据表的改编者和人口放在不同的线上,并且把每个行动都等待到你继续之前完成。

下面的法典是用“灯塔”写成的,可能甚至汇编成册,但希望你们能够这样做。

// Setup state as a parameter object containing a table and adapter to use to populate that table here

void DoWork()
{
    List<AutoResetEvent> signals = GetNumberOfWaitHandles(2);

    var params1 = new DataWorkerParameters
        {
            Command = GetCommand1();
            Table = new DataTable();
        }

    var params2 = new DataWorkerParameters
        {
            Command = GetCommand2();
            Table = new DataTable();
        }

    ThreadPool.QueueUserWorkItem(state => 
        {
            var input = (DataWorkerParameters)state;
            PopulateTable(input);
            input.AutoResetEvent.Set(); // You can use AutoResetEvent.WaitAll() in the caller to wait for all threads to complete
        },
        params1
    );

    ThreadPool.QueueUserWorkItem(state => 
        {
            var input = (DataWorkerParameters)state;
            PopulateTable(input);
            input.AutoResetEvent.Set(); // You can use AutoResetEvent.WaitAll() in the caller to wait for all threads to complete
        },
        params2
    );

    WaitHandle.WaitAll(signals.ToArray());
}


void PopulateTable(DataWorkerParameters parameters)
{
    input.Command.ExecuteReader();
    input.Table.Load(input.Command);
}

友情链接