Как организовать корректную работу потоков с одним файлом

@shafttt · Регистрация: 01.04.2012

Студворк — интернет-сервис помощи студентам

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
private void button1_Click(object sender, EventArgs e)
        {
            for (int p = 0; p < 2; p++)
            {
                Thread t = new Thread(pop);
                t.Start();
            }
        }
 
 
 
 
 private void pop()
        {
            var sync = SynchronizationContext.Current;
 
            
                Dictionary<string, string> accounts = new Dictionary<string, string>();
 
                foreach (string combo in File.ReadAllLines("acc.txt"))
                {
                    
                        string[] values = combo.Split(':');
                        if (values.Length >= 2 && !accounts.ContainsKey(values[0]))
                            accounts.Add(values[0], values[1]);
                    
                }
 
                foreach (KeyValuePair<string, string> kvp in accounts)
                {
 
 
                    string email = kvp.Key;
                    string password = kvp.Value;
 
                    string parsmail;
                    parsmail = Regex.Match(email, @"([^>]*)@").Groups[1].Value;
                    string pardomain;
                    pardomain = Regex.Match(email, @"@([^>]*)").Groups[1].Value;
                
                try
                {

В несколько потоков берутся одни и тежи данные с acc.txt
Нашёл решение lock() но не могу понять как тут его применить

Добавлено через 11 часов 29 минут
никто не подскажет?

Добавлено через 3 часа 31 минуту
Как вообще с тхт в потоке поочереде берутся строки... гугл непомогает (

Добавлено через 1 час 53 минуты

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 string st;
        private Object lockThis = new Object();
        private void button1_Click(object sender, EventArgs e)
        {
 
            for (int p = 0; p < 2; p++)
            {
                Thread t = new Thread(pop);
                t.Start();
            }
 
 
        }
 
        private void pop()
        {
 
            StreamReader sr = File.OpenText("123.txt");
 
            while (true)
            {
                lock (lockThis)
                {
                    st = sr.ReadLine();
                    if (st == null)
                        break;
                }
                richTextBox1.Invoke((MethodInvoker)delegate { richTextBox1.Text += st + "\n"; });
            }
 
        }

Народ есть какие нить мысли по этому вопросу?

@C17H19NO3 · 08.05.2012, 22:35

а в чем ошибка? вроде все правильно написал. Какую ошибку выдает??

можно еще читать построчно в List<>, через Split('/n'), а потом в цыкле "for" лочить только ту часть кода (list[i]), которая читает строку

C#
1
2
3
4
5
6
// код
       lock(thisLock)
         {
            list[i]
         }
       // код

или попробуй еще так. но тоже лочить не плностью все чтение, а только ту часть кода, где берутся значение это и будет ndоя прочитаная строчка и тогда любой поток сможет взять инфу.

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
StreamReader reader = new StreamReader("proba.txt");
            object thisLock = new object();
            while ((s = reader.ReadLine()) != null)
            {
                lock(thisLock)
                {
                  string[] split = s.Split(';');
                  int x = Int32.Parse(split[0]);
                  int y = Int32.Parse(split[1]);
                  dataGridView1.CurrentCell = dataGridView1.Rows[x].Cells[y];
                  dataGridView1.CurrentCell.Style.BackColor = Color.Red;
                }
            }
            reader.Close();

@shafttt · 08.05.2012, 23:26 **[ТС]**

Ошибки нету не какой, просто текст теряется и мясо получается при выводе...
В Общем тока 1 вариант лочить всё

@C17H19NO3 · 08.05.2012, 23:45

а что дальше с данными ты делаешь? прочитал строку одним потоком, а дальше что? просто если ты хочешь прочытать текст несколькими потоками, то в этом должна быть логика и продолжение. Вот именно, что получается мясо, а если лочить чтение одной строки, тогда каждому потоку будет передаваться по строке.

@shafttt · 09.05.2012, 00:14 **[ТС]**

Дальше идёт запрос с этими данными, где и нужны потоки..

@Savvy · 09.05.2012, 00:19

shafttt, почитай про семафоры и мьютексы.
Чем тебя не устраивает вариант вычитки файла в 1 поток скажем, в конструкторе класса, а потом при создании потоков раздавать им нужные строки? ведь при использовании мьютекса, быстродействие извлечения строк из файла ничем не будет отличатся от однопоточного решения.

@C17H19NO3 · 09.05.2012, 12:03

приблизительно можно сделать так

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
using System.IO;
using System.Threading;
 
namespace WindowsFormsApplication3
{
    public partial class Form1 : Form
    {
        static object thisLock = new object();
        List<string> list = new List<string>();
        Thread[] potok = new Thread[3];
        Thread th;
 
 
        public Form1()
        {
            InitializeComponent();
        }
 
        private void button1_Click(object sender, EventArgs e)
        {
            string line;
            StreamReader reader = new StreamReader("proba.txt");
            while ((line = reader.ReadLine()) != null)
            {
                string[] split = line.Split('\n');
                list.AddRange(split);
            }
        }
 
        private void button2_Click(object sender, EventArgs e)
        {
            string line;
            StreamReader reader = new StreamReader("proba.txt");
            while ((line = reader.ReadLine()) != null)
            {
                string[] split = line.Split('\n');
                list.AddRange(split);
            }
 
 
            for (int i = 0; i < potok.Length; i++)
            {
                potok[i] = new Thread(new ThreadStart(proc));
                potok[i].IsBackground = true;
                Thread.Sleep(1000);
                potok[i].Start();
            }
        }
 
        private void proc()
        {
            int ptr = 0;
            while (ptr < list.Count)
            {
                string curVal;
                lock(thisLock)
                {
                    curVal = list[ptr++];
                }
       
                    if (listBox1.InvokeRequired) listBox1.BeginInvoke(new Action(() => { listBox1.Items.Add(list[curVal] + " // thread number:" + Thread.CurrentThread.ManagedThreadId); }));
                    else listBox1.Items.Add(list[curVal] + " // thread number:" + Thread.CurrentThread.ManagedThreadId);
            }
        }
    }
}

@shafttt · 09.05.2012, 12:16 **[ТС]**

Сделал так...

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
 bool CanRead = false;
        //
        StreamReader sr = null;
        //
        private Object lockThis = new Object();
         
       
        private void button1_Click(object sender, EventArgs e)
        {
            sr = File.OpenText("acc.txt");
            CanRead = true;
            int i = Convert.ToInt32(textBox2.Text);
            
            
            for (int p = 0; p < i; p++)
            {
                Thread t = new Thread(pop);
                t.Start();
                
            }
        }
 
 
 private void pop()
        {
            var sync = SynchronizationContext.Current;
            string st;
            string mail;
            string password;
            string user;
            string domain;
            
 
            while (true)
            {
                lock (lockThis)
                {
 
                    if (CanRead)
                    {
                        
                        st = sr.ReadLine();
                        
                        if (st == null)
                        {
                            CanRead = false;
                            sr.Close();
                            break;
                        }//if (st == null)
 
                        lock (lockThis) textBox1.Invoke((MethodInvoker)delegate { textBox1.Text += st + "\n"; });
                        
                      
                    }//if (CanRead)
 
                    else break;
                }// lock (lockThis)
 
                 try
                    {

@C17H19NO3 · 09.05.2012, 13:40

в принципе можно, но всегда старайтесь лочить как можно меньше кода.

@outoftime · 09.05.2012, 17:17

shafttt, зачем оно тебе вообще надо? не проще ли юзать http://redis.io/ ?

@shafttt · 09.05.2012, 17:48 **[ТС]**

outoftime, Я разобрался норм всё!

@Niades · 09.05.2012, 22:17

Я бы для начала объявил структуру, которая будет хранить данные об аккаунте, например:

C#
1
2
3
4
5
6
7
8
9
10
11
struct Account
    {
         //Добавь еще какие тебе нужны поля, если нужны
         public string email;
         public string password;
         public Account(string email, string password)
         {
           this.email = email;
           this.password = password;
         }
}

Потом считал бы сразу данные о всех аккаунтах из нашего файла в очередь (Queue):

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
        Queue<Account> accounts;
        private void LoadAccounts()
        {
            accounts = new Queue<Account>();
            foreach (string line in File.ReadAllLines("acc.txt"))
            {
                string[] data = line.Split(':');
                //Тут тоже надо будет переписать, если нужны какие-то данные кроме мыла
                //и пароля
                Account account = new Account(data[0], data[1]);
                accounts.Enqueue(account);
            }
        }

А потом уже в потоках брал бы данные из коллекции, а не файла:

C#
1
2
3
4
5
6
7
private void Pop()
        {
            if (accounts.Count == 0)
                return;
            Account account = accounts.Dequeue();
            //Делаешь что хочешь с данными
        }

@shafttt · 09.05.2012, 22:59 **[ТС]**

Niades, Это уже интересней...
а оперативки будет больше кушать?

@агерон · 09.05.2012, 23:51

можно сделать так

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Text.RegularExpressions;
using System.Threading;
 
namespace WindowsFormsApplication2
{
    public class DataAccount
    {
        public string Email { get; set; }
        public string Domain { get; set; }
 
        public DataAccount(string email, string domain)
        {
            Email = email;
            Domain = domain;
        }
    }
 
    public class ParseEventArgs:EventArgs
    {
        public List<DataAccount> Accounts { get; set; }
 
        public ParseEventArgs(List<DataAccount> accounts)
        { Accounts = accounts; }
    }
 
    public class ParserAccounts
    {
        public event EventHandler<ParseEventArgs> Parsed = delegate { };
 
        protected IEnumerable<string> GetFileData(StreamReader reader)
        {
            while (!reader.EndOfStream)
                yield return reader.ReadLine();
        }
 
        protected Match GetMatch(string data, string pattern)
        { return Regex.Match(data, pattern, RegexOptions.Compiled | RegexOptions.IgnoreCase); }
 
        protected string GetValueMatch(string data, string pattern)
        {
            Match match = GetMatch(data, pattern);
            if (match.Success)
                return match.Value;
            return string.Empty;
        }
 
        protected string ParseEmail(string data)
        {
            const string pattern = @"([^>]*)@";
            return GetValueMatch(data, pattern);
        }
 
        protected string ParseDomain(string data)
        {
            const string pattern = @"@([^>]*)";
            return GetValueMatch(data, pattern);
        }
 
        public void Parse(string pathToFile)
        {
            ThreadPool.QueueUserWorkItem((object sender) =>
            {
 
                string email = string.Empty;
                string domain = string.Empty;
                List<DataAccount> accounts = new List<DataAccount>();
                using (StreamReader reader = File.OpenText(pathToFile))
                    foreach (string value in GetFileData(reader))
                    {
                        email = ParseEmail(value);
                        domain = ParseDomain(value);
                        accounts.Add(new DataAccount(email, domain));
                    }
                Parsed(this, new ParseEventArgs(accounts));
            }); 
        }
    }
}

а потом

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Collections;
using System.IO;
using System.Text.RegularExpressions;
using System.Threading;
 
namespace WindowsFormsApplication2
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
        private void button1_Click(object sender, EventArgs e)
        {
            ParserAccounts parser = new ParserAccounts();
            parser.Parsed += new EventHandler<ParseEventArgs>(parser_Parsed);
            parser.Parse("account.txt");
        }
 
        void parser_Parsed(object sender, ParseEventArgs e)
        {
            //e.Accounts <- твоя коллекция акков
            //твой код обработки акков
        }
    }
}

Новые блоги и статьи Все статьи Все блоги /
Загрузка PNG-файла с альфа-каналом с помощью библиотеки SDL3_image на Android 8Observer8 27.01.2026 Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .	влияние грибов на сукцессию anaschu 26.01.2026 Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .	Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android 8Observer8 26.01.2026 Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .	Установка Android SDK, NDK, JDK, CMake и т.д. 8Observer8 25.01.2026 Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .
Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf 8Observer8 25.01.2026 Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .	Использование SDL3-callbacks вместо функции main() на Android, Desktop и WebAssembly 8Observer8 24.01.2026 Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .	моя боль iceja 24.01.2026 Выложила интерполяцию кубическими сплайнами www. iceja. net REST сервисы временно не работают, только через Web. Написала за 56 рабочих часов этот сайт с нуля. При помощи perplexity. ai PRO , при. . .	Модель сукцессии микоризы anaschu 24.01.2026 Решили писать научную статью с неким РОманом

@shafttt 0 / 0 / 1 Регистрация: 01.04.2012 Сообщений: 46
	08.05.2012, 23:26 [ТС]
	Ошибки нету не какой, просто текст теряется и мясо получается при выводе... В Общем тока 1 вариант лочить всё 0

@C17H19NO3 218 / 212 / 63 Регистрация: 17.04.2012 Сообщений: 382
	08.05.2012, 23:45
	а что дальше с данными ты делаешь? прочитал строку одним потоком, а дальше что? просто если ты хочешь прочытать текст несколькими потоками, то в этом должна быть логика и продолжение. Вот именно, что получается мясо, а если лочить чтение одной строки, тогда каждому потоку будет передаваться по строке. 0

@shafttt 0 / 0 / 1 Регистрация: 01.04.2012 Сообщений: 46
	09.05.2012, 00:14 [ТС]
	Дальше идёт запрос с этими данными, где и нужны потоки.. 0

@Savvy 123 / 121 / 6 Регистрация: 21.12.2011 Сообщений: 348
	09.05.2012, 00:19
	shafttt, почитай про семафоры и мьютексы. Чем тебя не устраивает вариант вычитки файла в 1 поток скажем, в конструкторе класса, а потом при создании потоков раздавать им нужные строки? ведь при использовании мьютекса, быстродействие извлечения строк из файла ничем не будет отличатся от однопоточного решения. 0

@C17H19NO3 218 / 212 / 63 Регистрация: 17.04.2012 Сообщений: 382
	09.05.2012, 13:40
	в принципе можно, но всегда старайтесь лочить как можно меньше кода. 1

@outoftime ║XLR8║ 1212 / 909 / 270 Регистрация: 25.07.2009 Сообщений: 4,360 Записей в блоге: 5
	09.05.2012, 17:17
	shafttt, зачем оно тебе вообще надо? не проще ли юзать http://redis.io/ ? 0

@shafttt 0 / 0 / 1 Регистрация: 01.04.2012 Сообщений: 46
	09.05.2012, 17:48 [ТС]
	outoftime, Я разобрался норм всё! 0

@shafttt 0 / 0 / 1 Регистрация: 01.04.2012 Сообщений: 46
	09.05.2012, 22:59 [ТС]
	Niades, Это уже интересней... а оперативки будет больше кушать? 0