Синхронизация ресурсов

17.12.2012, 23:02. **Показов** 1309. **Ответов** 2

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

Всем привет! Такая проблема, я никак не могу понять как же синхронизировать ресурсы. Вот накатал код для примера:

Java
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
import java.util.ArrayList;
 
class Main {
 
    private ArrayList array;
 
    Runnable r1 = new Runnable() {
        @Override
        public void run() {
            while (true) {
                try {
                    for (int i = 0; i < array.size(); i++) {
                        //  удаляем элемент из массива
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    };
 
    Runnable r2 = new Runnable() {
        @Override
        public void run() {
            while (true) {
                try {
                    for (int i = 0; i < array.size(); i++) {
                        //  вызываем метод у удаленного элемента массива
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    };
 
    private void create() {
        array = new ArrayList();
        for (int i = 0; i < 10; i++) {
            array.add(new Object());
        }
        new Thread(r1).start();
        new Thread(r2).start();
    }
 
    public static void main(String args[]) {
        new Main().create();
    }
}

Как понятно из когда, у нас вылезет NullPointerException. Собственно как же организовать синхронизированный доступ к ресурсам?

@lemegeton · 18.12.2012, 00:01

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
import java.util.ArrayList;
import java.util.Collection;
import java.util.Random;
import java.util.concurrent.ConcurrentLinkedQueue;
 
class Doer<T> implements Runnable {
    public static Random random = new Random();
    private ConcurrentLinkedQueue<T> queue;
    private volatile boolean stopped;
 
    public Doer(ConcurrentLinkedQueue<T> queue) {
        this.queue = queue;
        this.stopped = false;
    }
 
    void stop() {
        stopped = true;
    }
 
    @Override
    public void run() {
        while (!(stopped && queue.isEmpty())) {
            if (!queue.isEmpty()) {
                T item = queue.poll();
                int sleepTime = random.nextInt(300);
                System.out.println("Thread " + Thread.currentThread().getName() + " got " + item + " will sleep for " + sleepTime + "ms");
                try {
                    Thread.sleep(sleepTime);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
 
public class TutorialThreads {
 
    public static void main(String[] args) throws InterruptedException {
        ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<Integer>();
        Collection<Thread> threads = new ArrayList<Thread>(3);
        Collection<Doer<Integer>> doers = new ArrayList<Doer<Integer>>(3);
 
        for (Integer i = 0; i < 3; ++i) {
            Doer<Integer> doer = new Doer<Integer>(queue);
            Thread thread = new Thread(doer, i.toString());
            doers.add(doer);
            threads.add(thread);
            thread.start();
        }
 
        for (int i = 0; i < 100; ++i)
            queue.offer(i);
 
        for (Doer<Integer> doer : doers)
            doer.stop();
        for (Thread thread : threads)
            thread.join();
    }
}

18.12.2012, 00:16

Поясните пожалуйста код, я не очень понял про очереди. Точнее даже не про очереди, а про Concurrent.
И можно ли как-то обойтись synhronized?

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11680&d=1772460536 Одним из. . .	Реалии 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. . . .
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .	Конвертировать закладки radiotray-ng в m3u-плейлист damix 19.02.2026 Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .	Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI Eddy_Em 18.02.2026 Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .

turboNadya
	18.12.2012, 00:16
	Поясните пожалуйста код, я не очень понял про очереди. Точнее даже не про очереди, а про Concurrent. И можно ли как-то обойтись synhronized?