2 BackgroundWorker параллельно

@Сид · Регистрация: 30.04.2009

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

Один BackgroundWorker пускаю на копирование файлов. Второй на запись этих файлов в базу.

C#
1
2
bgUnZipToFtp.RunWorkerAsync();
bgToBase1.RunWorkerAsync();

запускаю, первый поток выполняется, второй нет. Запускаю ещё раз(первый поток выполнен после первого запуска) второй поток отрабатывает нормально. В чём косяк?

@Dzhej-Dzhej · 09.12.2010, 10:39

возможно они пытаются одновременно открыть один и тот же файл

@Сид · 09.12.2010, 14:16 **[ТС]**

нет с этим всё ровно,1-ым потоком кладу в директорию откуда будут писаться в базу с отличным расширением(в частности $$$), а затем меняю на то, которое будет хавать поток записи в базу.Хотя кто знает,но в Delphi нормально работало.

@Unril · 09.12.2010, 19:52

Говорить о проблеме не видя кода, на мой взгляд, довольно глупо. Ясновидение есть только у редких избранных.

@Сид · 10.12.2010, 10:04 **[ТС]**

не чувак,глупо верить в ясновидящих)

@r0fL · 10.12.2010, 10:38

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

@Сид · 10.12.2010, 12:00 **[ТС]**

не, в обоих стоит бесконечный цикл, вот код обоих потоков:

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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
//поток записи в базу
private void bgToBase1_DoWork(object sender, DoWorkEventArgs e)
    {
      int i, nStrCount;
      string[] array;
      if (Directory.Exists(dirIn))
      {
        while (true)
        {
          if (!File.Exists(Directory.GetCurrentDirectory() + @"\Log\" + DateTime.Now.ToString("MM.dd.yyyy") + ".log"))
          {
            StreamWriter sw = File.CreateText(Directory.GetCurrentDirectory() + @"\Log\" + DateTime.Now.ToString("MM.dd.yyyy") + ".log");
            sw.Close();
          }
          StreamWriter srLog = File.AppendText(Directory.GetCurrentDirectory() + @"\Log\" + DateTime.Now.ToString("MM.dd.yyyy") + ".log");
          DirectoryInfo dirOut = new DirectoryInfo(dirIn);
          foreach (FileInfo fFile in dirOut.GetFiles("*.*F"))
          {
            FileStream fsFile = new FileStream(dirIn + fFile.Name, FileMode.Open, FileAccess.Read);
            StreamReader srFile = new StreamReader(fsFile);
            nStrCount = File.ReadAllLines(dirIn + fFile.Name).Count();
            i = 0;
            while (srFile.ReadLine() != null)
            {
              if (i > 0)
              {
                goRec = true;
                array = divStr(srFile.ReadLine(), '|');
                queryEx("SELECT Barcode FROM Production_Piter.dbo.Tts_CSV WHERE Barcode=" + array[2].ToString());
                if (ds.Tables[0].Rows.Count != 0)
                {
                  queryEx("DELETE FROM Production_Piter.dbo.Tts_CSV WHERE Barcode=" + array[2].ToString());
                }
                if (queryEx("INSERT INTO Production_Piter.dbo.Tts_CSV(OperType ,OperDate,Barcode,IndexTo,MailDirect,TransType," +
                        " MailType,MailCtg,MailRank,SendCtg,PostMark,Mass,Payment,Value,PayType," +
                        " MassRate,InsrRate,AirRate,AdValTax,SaleTax,Rate,OperAttr,IndexOper," +
                        " IndexNext,Comment,InsDate)" +
                        " SELECT 1,'" + array[1] + "','" + array[2] + "','" + array[3] + "','" + array[4] + "','" + array[5] +
                        "','" + array[6] + "','" + array[7] + "','" + array[8] + "','" + array[9] + "','" + array[10] +
                        "','" + array[11] + "','" + array[12] + "','" + array[13] + "','" + array[14] + "','" + array[15] +
                        "','" + array[16] + "','" + array[17] + "','" + array[18] + "','" + array[19] + "','" + array[20] +
                        "','" + array[21] + "','" + array[22] + "','" + array[23] + "','qwer',GETDATE()") == true)
                {
                  bgToBase1.ReportProgress(0, "[" + DateTime.Now.ToString("MM.dd.yyyy") + " - " + DateTime.Now.ToString("hh:mm:ss") + "] Скопирована строка-" + i.ToString() + " из " + (nStrCount - 1).ToString() + " - Имя файла: " + fFile.Name + "\n");
                }
                else
                {
                  StreamWriter sw1 = File.AppendText("[" + DateTime.Now.ToString("MM.dd.yyyy") + " - " + DateTime.Now.ToString("hh:mm:ss") + "] Ошибка записи файла-" + fFile.Name + ", Строка " + i.ToString() + " из " + (nStrCount - 1).ToString());
                  sw1.Close();
                }
              }
              goRec = false;
              i++;
            }
            srFile.Close();
            nFilesCount++;
            bgToBase1.ReportProgress(0, "[" + DateTime.Now.ToString("mm.dd.yyyy") + " - " + DateTime.Now.ToString("hh:mm:ss") + "] Записан в базу файл-" + fFile.Name + ", Кол-во записей " + (nStrCount - 1).ToString() + "\n");
            srLog.WriteLine("[" + DateTime.Now.ToString("mm.dd.yyyy") + " - " + DateTime.Now.ToString("hh:mm:ss") + "] Записан в базу файл-" + fFile.Name + ", Кол-во записей " + (nStrCount - 1).ToString());
            File.Delete(dirIn + fFile.Name);
          }
          srLog.Close();
        }
      }
      else
      {
        MessageBox.Show("Отсутствует директория dirIn." +
                        "Приложение будет закрыто.", "Внимание", MessageBoxButtons.OK, MessageBoxIcon.Exclamation);
        Environment.Exit(0);
      }  
    }
 
//поток: разжимаем, пишем на FTP,а затем в архив
    private void bgUnZipToFtp_DoWork(object sender, DoWorkEventArgs e)
    {
      DirectoryInfo dirOut = new DirectoryInfo(dirOut1);
      DirectoryInfo dir1 = new DirectoryInfo(dirIn + @"1\");
      string rename, extens;
      FastZip zip = new FastZip();
      while (true)
      {
        if (Directory.Exists(dirOut1))
        {
          if (Directory.Exists(dirIn))
          {
            foreach (FileInfo fFile in dirOut.GetFiles("*.*F"))
            {
              try
              {
                File.Copy(fFile.FullName, dirArch1 + fFile.Name, true);
                ftpCon.UploadFile(dirOut1 + fFile.Name, fFile.Name, true);
                rename = Path.ChangeExtension(fFile.FullName, "zip");
                File.Move(fFile.FullName, rename);
                zip.ExtractZip(rename, dirIn + @"1\", "");
                File.Delete(rename);
                foreach (FileInfo fFile1 in dir1.GetFiles("*.*F"))
                {
                  rename = Path.GetFileNameWithoutExtension(fFile1.FullName);
                  extens = Path.GetExtension(fFile1.FullName);
                  File.Move(fFile1.FullName, dirIn + rename + ".$$$");
                  File.Move(dirIn + rename + ".$$$", dirIn + rename + extens);
                }
              }
              catch (Exception exept)
              {
                MessageBox.Show(exept.Message);
              }
            }
          }
          else
          {
            MessageBox.Show("Директории sourceIn не существует", "Внимание", MessageBoxButtons.OK, MessageBoxIcon.Exclamation);
            Environment.Exit(0);
          }
        }
        else
        {
          MessageBox.Show("Директории sourceOut1 не существует", "Внимание", MessageBoxButtons.OK, MessageBoxIcon.Exclamation);
          Environment.Exit(0);
        }
      }
    }

Konctantin · 10.12.2010, 14:12

А покажите код, создания потоков, так на всякий случай.

PS. Уважаемый, перепишите пожалуйста код с использованием форматной строки, вам самому будет приятно:

C#
1
StreamWriter sw1 = File.AppendText(string.Format("[{0:yyyy.MM.dd-hh:mm:ss}] Ошибка записи файла- {1}, Строка: {2} из {3}", DateTime.Now, fFile.Name, i, nStrCount - 1));

@Сид · 10.12.2010, 15:28 **[ТС]**

А покажите код, создания потоков, так на всякий случай.

какой код? 2 компонента "BackgroundWorker". Кидаешь на форму компонент и вперёд.
PS: спасибо за совет, но именно мне приятнее от такого оформления не будет

Konctantin · 10.12.2010, 18:10

какой код? 2 компонента "BackgroundWorker". Кидаешь на форму компонент и вперёд.

ага, и стартонет оно само...

но именно мне приятнее от такого оформления не будет

это ваше дело

@Сид · 13.12.2010, 11:26 **[ТС]**

а как они стратуют написано в первом сообщении

Один BackgroundWorker пускаю на копирование файлов. Второй на запись этих файлов в базу.

C#
1
2
bgUnZipToFtp.RunWorkerAsync();
bgToBase1.RunWorkerAsync();

запускаю, первый поток выполняется, второй нет. Запускаю ещё раз(первый поток выполнен после первого запуска) второй поток отрабатывает нормально. В чём косяк?

Новые блоги и статьи Все статьи Все блоги /
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .	Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .
SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .	Реалии Hrethgir 01.03.2026 Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .	Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .

@Dzhej-Dzhej Заблокирован
	09.12.2010, 10:39
	возможно они пытаются одновременно открыть один и тот же файл 0

@Сид 3 / 3 / 0 Регистрация: 30.04.2009 Сообщений: 35
	09.12.2010, 14:16 [ТС]
	нет с этим всё ровно,1-ым потоком кладу в директорию откуда будут писаться в базу с отличным расширением(в частности $$$), а затем меняю на то, которое будет хавать поток записи в базу.Хотя кто знает,но в Delphi нормально работало. 0

@Unril 826 / 717 / 110 Регистрация: 06.10.2010 Сообщений: 825 Записей в блоге: 1
	09.12.2010, 19:52
	Говорить о проблеме не видя кода, на мой взгляд, довольно глупо. Ясновидение есть только у редких избранных. 1

@Сид 3 / 3 / 0 Регистрация: 30.04.2009 Сообщений: 35
	10.12.2010, 10:04 [ТС]
	не чувак,глупо верить в ясновидящих) 0

@r0fL Кодило 251 / 179 / 23 Регистрация: 25.11.2009 Сообщений: 685
	10.12.2010, 10:38
	Думаю, когда начинает выполняться второй поток - еще нет скопированных файлов первым потоком и, соответственно, он завершается, при втором использовании, уже скопированные файлы в директории есть - второму потоку есть с чем работать, он выполняется. 0