Форум программистов, компьютерный форум, киберфорум
Java SE (J2SE)
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.96/25: Рейтинг темы: голосов - 25, средняя оценка - 4.96
6 / 6 / 0
Регистрация: 17.09.2012
Сообщений: 104

Многопоточный счетчик

19.05.2015, 22:18. Показов 5436. Ответов 7
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Есть задание: реализовать многопоточный счетчик.

Имеется Map<String, Integer> в который записывается кол-во посещений страниц сайта.
Создать 50 потоков , имитирующих клиентские соединения от 5 страниц по 10 параллельных запросов,
в которых увеличивать счетчик своей страницы. Оценить корректность работы и производительность.

Есть реализация задания, но её не принимают, т.к. "счётчик однопоточный".

Помогите пожалуйста реализовать многопоточность.

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
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
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
 
public class Counterr {
 
    Map<String, Integer> mySite = new LinkedHashMap<String, Integer>();
    Random rand = new Random();
 
    private static AtomicInteger threadCount = new AtomicInteger(0);
 
    public void execute() throws InterruptedException {
 
        int numberAll = 10;
        for (int i = 0; i < 50; i++) {
            threadCount.incrementAndGet();
        }
        System.out.println("threadCount (before) = " + threadCount.get());
 
 
        for (int i = 1; i <= numberAll; i++) {
            mySite.put("http://mysite.ru/page".concat(Integer.toString(i)),0);
        }
 
 
        long start = System.currentTimeMillis();
        String[] url = new String[5];
        for (int i = 0; i < 50; i++) {
            for (int k=0;k<5;k++){
                url[k] = "http://mysite.ru/page".concat(Integer.toString(rand.nextInt(numberAll)+1));
            }
            User visitor = new User(url);
            new Thread(visitor).start();
            Thread.sleep(5);
 
        }
        System.out.println("-------------------------");
        System.out.println("Finished in " + (System.currentTimeMillis() - start) + " mls");
        System.out.println("-------------------------");
        Thread.sleep(500);
 
 
        //вывод на экран страниц с частотой их посещения
        int counterAll = 0;
        for (Map.Entry<String, Integer> entry : mySite.entrySet()) {
            System.out.println("Страница сайта:   "+entry.getKey()+"      ;      Количество посещений:   "+entry.getValue());
            counterAll = counterAll + entry.getValue();
        }
        Thread.sleep(500);
        System.out.println("-------------------------");
        Thread.sleep(500);
        System.out.println("Всего посещений сайта: ".concat(Integer.toString(counterAll)));
        System.out.println("threadCount (after) = " + threadCount.get());
    }
 
    private class User implements Runnable {
 
        private String[] url;
        public User(String[] url) {
            this.url = url;
        }
 
        @Override
        public void run() {
            for (int i=1;i<=10;i++){
                for (int j=0;j<5;j++){
                    synchronized (mySite.get(url[j])) {
                        mySite.put(url[j], mySite.get(url[j]) + 1);
                        Thread.yield();
                    }
                }
            }
            threadCount.decrementAndGet();
        }
    }
 
    public static void main(String[] args) throws InterruptedException {
        new Counterr().execute();
    }
}
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
19.05.2015, 22:18
Ответы с готовыми решениями:

Многопоточный чат
Здравствуйте! Пишу чат, вот код Server import java.io.*; import java.net.ServerSocket; import java.net.Socket; import...

Многопоточный апплет
Написать многопоточный апплет, которий реализует гонки. С клавиатуры задается количество участников гонки, и нажимается клавиша...

Многопоточный чат
Здравствуйте. Помогите пожалуйста решить проблему. Нужно чтобы к сервер могло подключиться несколько клиентов, работа с ними должна идти в...

7
636 / 528 / 165
Регистрация: 01.04.2010
Сообщений: 1,843
20.05.2015, 06:42
Цитата Сообщение от stx Посмотреть сообщение
Создать 50 потоков , имитирующих клиентские соединения от 5 страниц по 10 параллельных запросов
Это как? Каждый (из 50) поток создаёт ещё 10 (или что понимается под параллельными запросами), которые случайным образом обращаются к этим 5 страницам?

Цитата Сообщение от stx Посмотреть сообщение
Имеется Map<String, Integer>
Именно такой интерфейс? А можно поменять на Map<String, AtomicInteger> или на Map<String, Number>?

Цитата Сообщение от stx Посмотреть сообщение
Java
1
2
3
for (int i = 0; i < 50; i++) {
    threadCount.incrementAndGet();
}
Помещение отапливаешь?
Кликните здесь для просмотра всего текста
Java
1
threadCount.set(50);
или
Java
1
threadCount = new AtomicInteger(50);
не вариант?
0
6 / 6 / 0
Регистрация: 17.09.2012
Сообщений: 104
20.05.2015, 14:35  [ТС]
Цитата Сообщение от aleksandy Посмотреть сообщение
Это как? Каждый (из 50) поток создаёт ещё 10 (или что понимается под параллельными запросами), которые случайным образом обращаются к этим 5 страницам?
Как я понимаю, это 5 страниц, к каждой странице обращается по 10 параллельных потоков, а всего потоков 50 на весь проект.

Цитата Сообщение от aleksandy Посмотреть сообщение
Именно такой интерфейс? А можно поменять на Map<String, AtomicInteger> или на Map<String, Number>?
Требование не строгое, насколько я понял.

Цитата Сообщение от aleksandy Посмотреть сообщение
Помещение отапливаешь?
Пытаюсь сдать задание.
Буду благодарен исправленному коду
0
636 / 528 / 165
Регистрация: 01.04.2010
Сообщений: 1,843
20.05.2015, 22:09
Цитата Сообщение от stx Посмотреть сообщение
5 страниц, к каждой странице обращается по 10 параллельных потоков
Всё просто: создаёшь поле Map<String, AtomicInteger>, инициализируешь его какой-нибудь потокобезопасной имплементацией, заполняешь значениями AtomicInteger(0) для каждого ключа. Затем пускаешь свои 50 потоков. В run методе каждого потока просто инкрементишь значение в мапе.
0
6 / 6 / 0
Регистрация: 17.09.2012
Сообщений: 104
20.05.2015, 22:34  [ТС]
Цитата Сообщение от aleksandy Посмотреть сообщение
Всё просто: создаёшь поле Map<String, AtomicInteger>, инициализируешь его какой-нибудь потокобезопасной имплементацией, заполняешь значениями AtomicInteger(0) для каждого ключа. Затем пускаешь свои 50 потоков. В run методе каждого потока просто инкрементишь значение в мапе.
К сожалению для меня это не просто.
Реально работающий пример можешь показать?
0
636 / 528 / 165
Регистрация: 01.04.2010
Сообщений: 1,843
21.05.2015, 01:23
Цитата Сообщение от stx Посмотреть сообщение
Реально работающий пример можешь показать?
Конечно могу, но не буду. Ты же учишься, я тебе и так всё по шагам расписал.
0
Эксперт Java
 Аватар для turbanoff
4094 / 3828 / 745
Регистрация: 18.05.2010
Сообщений: 9,331
Записей в блоге: 12
21.05.2015, 01:38
Цитата Сообщение от stx Посмотреть сообщение
Имеется Map<String, Integer> в который записывается кол-во посещений страниц сайта.
Нужно использовать именно LinkedHashMap? Или можно заменить на другую мапу? LinkedHashMap - не потокобезопасен.
0
6 / 6 / 0
Регистрация: 17.09.2012
Сообщений: 104
21.05.2015, 11:12  [ТС]
Цитата Сообщение от turbanoff Посмотреть сообщение
Нужно использовать именно LinkedHashMap? Или можно заменить на другую мапу? LinkedHashMap - не потокобезопасен.
Можно заменить.

Добавлено через 57 минут
Цитата Сообщение от aleksandy Посмотреть сообщение
Конечно могу, но не буду. Ты же учишься, я тебе и так всё по шагам расписал.
Уже отучился, оценки все поставили. Теперь это для общего развития.
Сравню две версии программы и попробую понять почему не принимали.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
21.05.2015, 11:12
Помогаю со студенческими работами здесь

Многопоточный .csv парсер
Доброго времени суток) Суть вопроса думаю понятна из заголовка. файл .csv содержит строки типа ...

Многопоточный HTML Парсер
Суть задачи состоит в том чтобы парсить html по ссылке на наличие email-ов, в случае наличия таковых, выводим ссылку и email-ы которые...

Многопоточный парсер, как организовать?
Привет всем зашедшим. Вот такая задача есть. Организовать что-то вроде мнoгoпoтoчного пapсера. Который будет следить за определенной...

Многопоточный поиск файла в файловой системе
Пользователь вводит имя файла и директорию в которой искать, если файл существует вывести где он находится. Как я думаю: Вводим...

Многопоточный вывод трех массивов - каждого в своей строке
Тема потоки Thread.Имеется три массива,как сделать так чтобы каждый массив выводился в новой строке:( public class Main { ...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
8
Ответ Создать тему
Новые блоги и статьи
Реалии
Hrethgir 01.03.2026
Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .
Ритм жизни
kumehtar 27.02.2026
Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .
SDL3 для Web (WebAssembly): Сборка SDL3 и Box2D из исходников с помощью 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 секунды (а то и больше),. . .
И ясному Солнцу
zbw 12.02.2026
И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru