class ImportRecordClass
    {
        public Int32 classIndex;
        public String classData;
    }



                    while ((ReadString[ReadStringCount] = sr.ReadLine()) != null)
                    {

                        tasks[ReadStringCount] = new Task((obj) => 
                                                 {
                                                     ImportRecordClass ImportRecord = (ImportRecordClass)obj;
                                                     importRecord(ref ImportRecord.classIndex, ref ImportRecord.classData);
                                                 }, 
                                                 new ImportRecordClass()
                                                 {
                                                     classIndex = ReadStringCount,
                                                     classData = ReadString[ReadStringCount]
                                                 });

                        tasks[ReadStringCount].Start();

                        if((ReadStringCount+1) % ReadBatchSize == 0)
                        {
                            Task.WaitAll(tasks);
                            ReadString = new String[ReadBatchSize];
                            ReadStringCount = 0;
                            
//                            table.Clear();
                        }

                        if ((++Records) % WriteBatchSize == 0)
                        {
                            Console.WriteLine("Records: {0} CurrentTime: {1}", Records, DateTime.Now);
                        }

                        ReadStringCount++;
                    }




        private static void importRecord(ref Int32 Index, ref String Data)
        {
            DataRow row = table.NewRow();

            String[] Columns = Data.Split('|');
            row[0] = col[0];
            row[1] = col[1];
            table.Rows.Add(row);
        }