Блокировка потока методом Lock

@NowMatrix · Регистрация: 14.01.2011

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

Всем добрый день. Что с потоками никак толком не разберусь. Метод lock как производит блокировку не совсем понятно. Вот цитата из книги:

XML
1
2
3
4
 "Инструкция lock гарантирует, что указанный блок кода, защищенный блоки-
ровкой для данного объекта, может быть использован только потоком, который полу-
чает эту блокировку. Все другие потоки остаются заблокированными до тех пор, пока
блокировка не будет снята. А снята она будет лишь при выходе из этого блока."

Не совсем понятно.Если поток не обращается к методу,он тоже будет заблокирован,пока другой поток не завершит работу?Допустим вот код:

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
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
 
namespace ConsoleApplication1
{
    class MyMeths
    {
        int summa;
        int multiply;
        public int SumArr(int[] nums)
        {
            lock (this)
            {
                summa = 0;
                for (int i = 0; i < nums.Length; i++)
                {
                    Console.WriteLine("Промежуточная сумма для потока <" +Thread.CurrentThread.Name+ "> равна :"+summa);
                    summa += nums[i];
                }
                return summa;
            }
        }
 
        public int MultiplyArr (int[] nums)
        {
            lock(this) 
            {
                multiply = 1;
                for (int i = 1; i < nums.Length+1; i++)
                {
                    Console.WriteLine("Промежуточное произведение для потока <" + Thread.CurrentThread.Name + "> равно :" + multiply);
                    multiply *= i;
                }
                return multiply;
            }
        }
    }
 
    class MyThread
    {
        int[] a;
        int answer; //сумма
        int mylt; //произведение
        public Thread thrd;
        MyMeths mymet = new MyMeths();
 
        public MyThread(string name,int[] nums)
        {
            thrd = new Thread(new ThreadStart(Run));
            thrd.Name = name;
            a = nums;
            thrd.Start();
        }
 
        void Run()
        {
            Console.WriteLine("<"+thrd.Name+"> стартовал");
            if (thrd.Name=="Сумма") 
            {
                answer = mymet.SumArr(a);
                Console.WriteLine("Сумма для потока <" + thrd.Name + "> равна " + answer);
            }
            if (thrd.Name == "Произведение") 
            {
                mylt = mymet.MultiplyArr(a);
                Console.WriteLine("Произведние для потока <"+thrd.Name+"> равно "+mylt);
            }
            Console.WriteLine("<"+thrd.Name + "> завершён");
        }
    }
 
    class Program
    {
        static void Main(string[] args)
        {
            int[] b = { 1, 2, 3, 4, 5 };
            MyThread mt1 = new MyThread("Сумма",b);
            MyThread mt2 = new MyThread("Произведение", b);
 
            mt1.thrd.Join();
            mt2.thrd.Join();
 
            Console.ReadKey();
        }
    }
}

Есть 2 метода,определённые в одном классе.Один суммирует массив,другой произведение вычисляет. Оба заблокированы.Делегат принимает метод Run в обоих созданных дочерних потоках(в Main()).В этом методе идёт разделение по именам потоков.Если одно имя - выполняем один метод,если другое,то другой метод. Т.е. если lock блокирует часть кода,которую использует поток (например №1) вызывая метод №1,то поток №2 не может разве обратиться к другому методу? Т.е. lock блокирует остальные потоки ,вне зависимости какую часть кода они пытаются использовать, пока не завершит выполнение.Или же lock блокирует остальные потоки именно к отдельной части кода? Да и вообще результаты программы разные. По идее если lock блокирует другие потоки(не зависимо к какой часть кода они обращаются),то сначала должен полностью выполниться первый поток,потом второй. А если lock блокирует только поток,вызвавший именно этот метод,то потоки должны выполняться о очереди,распределяя время ЦП. Направьте на истинный путь,запутался уже. Да и вообще результаты программы разные иногда. Т.е.то по очереди потоки выполняются,то один немного залезает во время выполнения другого.

@andrii · 07.12.2011, 12:31

этот кусок

C#
1
2
3
4
5
6
7
8
9
10
            lock(this) 
            {
                multiply = 1;
                for (int i = 1; i < nums.Length+1; i++)
                {
                    Console.WriteLine("Промежуточное произведение для потока <" + Thread.CurrentThread.Name + "> равно :" + multiply);
                    multiply *= i;
                }
                return multiply;
            }

lock(this) - устанавливает блокиратор на этот экземпляр через this, вот и 2 lock(this) будут выполнятся по очереди, то есть если 2 потока выполняют 2 метода, то никакой параллельности не будет ....
другой вариант(более правильный):
для метода суммирования

C#
1
2
3
4
object lockerForAdd = new object();
lock(lockerForAdd ){
//do your math
}

для умножения

C#
1
2
3
4
object lockerForMult = new object();
lock(lockerForMult ){
//do you math
}

так добились что суммирование и умножение 2 потоками для 1 экземпляра может выполнятся параллельно

@NowMatrix · 07.12.2011, 12:44 **[ТС]**

Спасибо,но результат тот же.Скрин выполнения программы использую первый мой код.Потом изменил как Вы посоветовали,результат тот же.

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
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
 
namespace ConsoleApplication1
{
    class MyMeths
    {
        int summa;
        int multiply;
        public int SumArr(int[] nums)
        {
            object aa = new object();
            lock (aa)
            {
                summa = 0;
                for (int i = 0; i < nums.Length; i++)
                {
                    Console.WriteLine("Промежуточная сумма для потока <" +Thread.CurrentThread.Name+ "> равна :"+summa);
                    summa += nums[i];
                }
                return summa;
            }
        }
 
        public int MultiplyArr (int[] nums)
        {
            object bb = new object();
            lock(bb) 
            {
                multiply = 1;
                for (int i = 1; i < nums.Length+1; i++)
                {
                    Console.WriteLine("Промежуточное произведение для потока <" + Thread.CurrentThread.Name + "> равно :" + multiply);
                    multiply *= i;
                }
                return multiply;
            }
        }
    }
 
    class MyThread
    {
        int[] a;
        int answer; //сумма
        int mylt; //произведение
        public Thread thrd;
        MyMeths mymet = new MyMeths();
 
        public MyThread(string name,int[] nums)
        {
            thrd = new Thread(new ThreadStart(Run));
            thrd.Name = name;
            a = nums;
            thrd.Start();
        }
 
        void Run()
        {
            Console.WriteLine("<"+thrd.Name+"> стартовал");
            if (thrd.Name=="Сумма") 
            {
                answer = mymet.SumArr(a);
                Console.WriteLine("Сумма для потока <" + thrd.Name + "> равна " + answer);
            }
            if (thrd.Name == "Произведение") 
            {
                mylt = mymet.MultiplyArr(a);
                Console.WriteLine("Произведние для потока <"+thrd.Name+"> равно "+mylt);
            }
            Console.WriteLine("<"+thrd.Name + "> завершён");
        }
    }
 
    class Program
    {
        static void Main(string[] args)
        {
            int[] b = { 1, 2, 3, 4, 5 };
            MyThread mt1 = new MyThread("Сумма",b);
            MyThread mt2 = new MyThread("Произведение", b);
 
            mt1.thrd.Join();
            mt2.thrd.Join();
 
            Console.ReadKey();
        }
    }
}

@kolorotur · 07.12.2011, 12:57

Сообщение от NowMatrix

C#
1
2
3
4
5
public int SumArr(int[] nums)
 {
 object aa = new object();
 lock (aa)
 {

Это равносильно тому, вообще убрать код синхронизации, так как вы замыкаетесь на локальном объекте, невидимом другим потокам по определению. В результате никакого замыкания не будет.

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

@Dzhej-Dzhej · 07.12.2011, 12:57

Попробую обьяснить.

Потоки друг друга не блокируют, они блокируют участок кода для работы с ним. Блокированный код может одновременно исполняться только одним потоком.
Если поток доходит до участка кода

C#
1
2
3
4
            lock (locker1)
            {
                //операторы
            }

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

Если используете для блокировок разных участков кода отдельные обьекты locker1, locker2,... , то эти блокировки никак не взаимосвязаны. Т.е. если один поток заблокировал lock (locker1){...}, другой поток не может работать только с этим учаском кода, пока тот не освободиться.

Примерно так.
------------------

Пока писал, уже ответили.
В вашем случае блокировки лишние, результат будет примерно одинаков.
Берете одни и те же данные, их не изменяете, а результаты записываете в разные переменные.

Блокируются "критические" участки кода.

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

Попробуйте выводить не на консоль(она потокобезопасная), а в один и тот же файл с блокировкой и без. И циклы побольше.

@andrii · 07.12.2011, 13:14

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
 public int SumArr(int[] nums)
        {
//этого объекта не должно тут быть,  он должен быть в глобальным для класса
            object aa = new object();
            lock (aa)
            {
                summa = 0;
                for (int i = 0; i < nums.Length; i++)
                {
                    Console.WriteLine("Промежуточная сумма для потока <" +Thread.CurrentThread.Name+ "> равна :"+summa);
                    summa += nums[i];
                }
                return summa;
            }
        }

так же для наглядности параллелизма добавьте задержку, Thread.Sleep(100);

Добавлено через 3 минуты
хотя у Вас ошибка на ошибке

Добавлено через 5 минут
вот Вам пример действительно параллельного выполнения

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
class MyMeths
    {
        int summa;
        int multiply;
        object lockerAdd = new object();
        object lockerMult = new object();
        public int SumArr(int[] nums)
        {
            lock (lockerAdd)
            {
                summa = 0;
                for (int i = 0; i < nums.Length; i++)
                {
                    Console.WriteLine("Промежуточная сумма для потока <" + Thread.CurrentThread.Name + "> равна :" + summa);
                    summa += nums[i];
                    Thread.Sleep(500);
                }
                return summa;
            }
        }
 
        public int MultiplyArr(int[] nums)
        {
            lock (lockerMult)
            {
                multiply = 1;
                for (int i = 1; i < nums.Length + 1; i++)
                {
                    Console.WriteLine("Промежуточное произведение для потока <" + Thread.CurrentThread.Name + "> равно :" + multiply);
                    multiply *= i;
                    Thread.Sleep(500);
                }
                return multiply;
            }
        }
    }
 
    class MyThread
    {
        int[] a;
        int answer; //сумма
        int mylt; //произведение
        public Thread thrd;
        MyMeths mymet = null;
 
        public MyThread(string name, int[] nums, MyMeths m)
        {
            thrd = new Thread(new ThreadStart(Run));
            thrd.Name = name;
            a = nums;
            mymet = m;
            thrd.Start();
        }
 
        void Run()
        {
            Console.WriteLine("<" + thrd.Name + "> стартовал");
            if (thrd.Name == "Сумма")
            {
                answer = mymet.SumArr(a);
                Console.WriteLine("Сумма для потока <" + thrd.Name + "> равна " + answer);
            }
            if (thrd.Name == "Произведение")
            {
                mylt = mymet.MultiplyArr(a);
                Console.WriteLine("Произведние для потока <" + thrd.Name + "> равно " + mylt);
            }
            Console.WriteLine("<" + thrd.Name + "> завершён");
        }
    }
 
    class Program
    {
        static void Main(string[] args)
        {
            int[] b = { 1, 2, 3, 4, 5 };
            MyMeths m = new MyMeths();
            MyThread mt1 = new MyThread("Сумма", b, m);
            MyThread mt2 = new MyThread("Произведение", b, m);
 
            mt1.thrd.Join();
            mt2.thrd.Join();
 
            Console.ReadKey();
        }
    }

@NowMatrix · 07.12.2011, 13:39 **[ТС]**

Ладно,услышал кое что однозначное для себя,буду разбираться.Спасибо всем за отзывчивость и объяснения.

Добавлено через 11 минут
Ну да я объектами для lock намудрил,не подумал что потоки не увидят их. И я понял,когда используем Thread.Sleep() - то приостанавливаем поток,давая другому доступ. Точнее не доступ,а время успеть отобразить на экране слова по очереди. Я просто не использовал этого.

Новые блоги и статьи Все статьи Все блоги /
Модульная разработка через 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 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .	SDL3 для Web (WebAssembly): Сборка библиотек: SDL3, Box2D, FreeType, SDL3_ttf, SDL3_mixer и SDL3_image из исходников с помощью CMake и Emscripten 8Observer8 27.02.2026 Недавно вышла версия 3. 4. 2 библиотеки SDL3. На странице официальной релиза доступны исходники, готовые DLL (для x86, x64, arm64), а также библиотеки для разработки под Android, MinGW и Visual Studio. . . .

@NowMatrix 98 / 81 / 16 Регистрация: 14.01.2011 Сообщений: 438
	07.12.2011, 13:39 [ТС]
	Ладно,услышал кое что однозначное для себя,буду разбираться.Спасибо всем за отзывчивость и объяснения. Добавлено через 11 минут Ну да я объектами для lock намудрил,не подумал что потоки не увидят их. И я понял,когда используем Thread.Sleep() - то приостанавливаем поток,давая другому доступ. Точнее не доступ,а время успеть отобразить на экране слова по очереди. Я просто не использовал этого. 0