Форум программистов, компьютерный форум, киберфорум
Программирование Android
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.62/13: Рейтинг темы: голосов - 13, средняя оценка - 4.62
420 / 357 / 47
Регистрация: 22.05.2013
Сообщений: 2,518

Тонкости потоков

08.04.2014, 23:00. Показов 2486. Ответов 7
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Не до конца понимаю что из себя представляет поток в яве андроида!
Сделал второй поток для помощи в отрисовке. Он в бесконечном цикле перебирает таблицу-очередь и обрабатывае лежащие в ней записи. Но... в тихом режиме он забирает 100% процессора! Даже если я ничего не трогаю. Попытался перед запуском понизить его приоритет
Tread1.setPriority(Thread.MIN_PRIORITY); //
Tread1.start();
Не помогло! Приходится ставить sleep(100) для потока. Это уменьшает нагрузку для процессора без сильных потерь. Но это подтормаживает его если в списке появляются новые записи - обрабатывает не сразу.
Перебор списка крайне простой! Примерно так:
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
        Tread1 = new Thread(new Runnable() { public void run() {
            Tread_Runed = true;
            while (Tread_Runed){
// без этого забирает 100% ядра!
//                sleep_redraw = 50;//теоретически можно менять
//                try { Thread.currentThread().sleep(sleep_redraw); } catch (Exception e) { }
                Tread_ListItem item;
                int size1;
                synchronized(mTreadArr) {
                    size1 = mTreadArr.size() - 1;
                }
                for (int i = size1 - 1; i >= 0; i--) {
                    synchronized(mTreadArr) {
                        if (i>=mTreadArr.size()) continue; // вдруг снаружи уменьшили список
                        item = mTreadArr.get(i);
                    }
                    if (!item.ok) {
                        RecalcItem(item);
                        item.ok = true;
                    }
                }
            }
        }});
        Tread1.setPriority(Thread.MIN_PRIORITY); //
        Tread1.start();
Сейчас подумываю схему динамической замены времени задержки (sleep) или поиграться в остановить/возобновить поток, но может есть более "правильный" способ???
0
Лучшие ответы (1)
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
08.04.2014, 23:00
Ответы с готовыми решениями:

Мини чат, тонкости разработки
Например приложение Viber и его аналоги.. Как в них реализован чат? А именно "ListView" с сообщениями. Допустим БД SQLlite с...

Тонкости ООП в SurfaceView. Можно ли написать графический движок?
Гуру ООП, помогите! Задумал написать свой микро-графический-движок. Хочу обьединить работу с Canvas и с OpenGL в одном классе....

Область видимости общей переменной для потоков + закрытие потоков
Есть два вопроса про потоки. Первый. Как можно сделать общую переменную для основного потока и моих ? struct ThreadInfo1 { int...

7
 Аватар для Netscape
374 / 361 / 52
Регистрация: 02.10.2009
Сообщений: 712
Записей в блоге: 4
09.04.2014, 13:44
sleep здесь вообще не нужен, а нужно здесь использовать wait/notify.
Т.е., когда нечего делать, поток не будет жрать процессорное время, а отдаст его другому потоку.

Добавлено через 26 секунд
ЗЫ: и никакие это не тонкости.
1
420 / 357 / 47
Регистрация: 22.05.2013
Сообщений: 2,518
09.04.2014, 17:02  [ТС]
Цитата Сообщение от Netscape Посмотреть сообщение
ЗЫ: и никакие это не тонкости.
Просто не ожидал что заберет на одноядерном устройстве ВСЕ ресурсы поцессора... ну там 3-5% если цикл холостой... и так и быть 70-80% при нагрузке!

Цитата Сообщение от Netscape Посмотреть сообщение
нужно здесь использовать wait/notify
Фишка в том что я не знаю когда нужен поток, а когда нет.
Есть 3 действия:
1) команда от первого потока: добавить новые записи в таблицу
2) команда от первого потока: удалить устаревшие записи из таблицы
3) циклически обработать новые через небольшой интервал времени (10-50мс) после добавления и пометить их как "старые".
Сейчас выкрутился так: Пока новых записей нет, интервал можно повысить, при добавлении нового уменьшить. После прокрутки цикла интервал повышается. Процессор заметно "остывает".

Если я "заморожу" цикл/поток после пробега по всем записям, а в это время будет добавлена новая запись и цикл/поток "разморожен", то я могу пропустить последнюю не учтенную запись и остановиться... Конечно стоит подумать об остановке через таймер - это остудит проц если пользователь забудет выйти из программы, но как вычислить интервал через который можно окончательно приостановить...

Но все равно спасибо! Примерно понял...
0
 Аватар для Netscape
374 / 361 / 52
Регистрация: 02.10.2009
Сообщений: 712
Записей в блоге: 4
09.04.2014, 17:11
Мне это напоминает классическую задачу Producer-Consumer, 1-й поток что-то "производит", т.е. отправляет команды, 2-й - "потребляет", т.е. исполняет эти команды.
вот пример реализации:
http://java67.blogspot.com/201... ample.html
0
420 / 357 / 47
Регистрация: 22.05.2013
Сообщений: 2,518
09.04.2014, 17:37  [ТС]
Возник вопрос:
Сколько потоков может быть в андроиде? Если будет 100-1000 анроид умрет? Зависит ли это от версии андроида?
0
 Аватар для Netscape
374 / 361 / 52
Регистрация: 02.10.2009
Сообщений: 712
Записей в блоге: 4
09.04.2014, 17:43
Цитата Сообщение от Tester64 Посмотреть сообщение
Сколько потоков может быть в андроиде? Если будет 100-1000 анроид умрет? Зависит ли это от версии андроида?
1. Сколько влезет в память. Thread Stack Size * Thread count < Available RAM
2. Не думаю, скорее всего будет брошен Exception. Или андроид убьет приложение. Можешь проверить.
3. Да, зависит.
1
420 / 357 / 47
Регистрация: 22.05.2013
Сообщений: 2,518
09.04.2014, 18:47  [ТС]
Цитата Сообщение от Netscape Посмотреть сообщение
1. Сколько влезет в память. Thread Stack Size * Thread count < Available RAM
Можете расшифровать это? Что здесь Stack Size ? Как узнать Available RAM ?

Цитата Сообщение от Netscape Посмотреть сообщение
Или андроид убьет приложение
А вот это критично! Данные не будут сохранены. Да и Exception непонятно где ловить! При попытке создать поток, в его теле, в момент синхронизации с основным потоком...

Цитата Сообщение от Netscape Посмотреть сообщение
3. Да, зависит.
Тоже поподробнее если можно! Просто Available RAM и Stack Size отличаются или реальные(встроенные в ядро) ограничения на количество потоков?

Цитата Сообщение от Netscape Посмотреть сообщение
Мне это напоминает классическую задачу Producer-Consumer
Спасибо, но моя задача уже намного сложнее этого примера. И даже уже придумал как подключить wait/notify. Чуть ускорило работу...
0
 Аватар для Netscape
374 / 361 / 52
Регистрация: 02.10.2009
Сообщений: 712
Записей в блоге: 4
10.04.2014, 16:05
Лучший ответ Сообщение было отмечено Tester64 как решение

Решение

Скажу сразу, я в этих вопросах не сильно компетентен, но попробую пояснить как это понимаю я сам.
Константу, которая отвечает за Thread stack size, можно найти в исходниках файла /vm/Thread.h.
#define kDefaultStackSize
по версиях:
API 3 (Android 1.5) = 8KB
API 4-10 (Android 1.6 - Android 2.3.7) = 12KB
API 14-19 (Android 4.0 - Android 4.4.2) = 16KB
Вот файл из исходников 4.4.2, строчка 79:
https://android.googlesource.c... m/Thread.h

Если под поток выделяется 16кб, то кажется, что когда их будет много, они сожрут всю доступную память, возможно, андроид начнет освобождать ее, убивая все что сможет убить, после чего получим OutOfMemoryError.
Скорее всего, выброшен он будет при попытке создания нового потока и выделения под него памяти.
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:640)
Добавлено через 1 час 38 минут
Решил проверить свою теорию.
pthread_create failed: couldn't allocate 1048576-byte stack
pthread_create (stack size 16384 bytes) failed: Try again

After creating 1,506 threads, java.lang.OutOfMemoryError: pthread_create (stack size 16384 bytes) failed: Try again
at java.lang.VMThread.create(Native Method)
at java.lang.Thread.start(Thread.java:1029)
Запускал на Samsung SIII, как видим, после создания 1,506 потоков, приложение благополучно упало.

Проверял этим:
Кликните здесь для просмотра всего текста
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
public class MainActivity extends ActionBarActivity {
 
    public static final int BATCH_SIZE = 40;
 
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
 
        List<Thread> threads = new ArrayList<Thread>();
        try {
            for (int i = 0; i <= 10 * 1000; i += BATCH_SIZE) {
                long start = System.currentTimeMillis();
                addThread(threads, BATCH_SIZE);
                long end = System.currentTimeMillis();
                Thread.sleep(500);
                long delay = end - start;
                System.out.printf("%,d threads: Time to create %,d threads was %.3f seconds %n", threads.size(), BATCH_SIZE, delay / 1e3);
            }
        } catch (Throwable e) {
            System.err.printf("After creating %,d threads, ", threads.size());
            e.printStackTrace();
        }
    }
 
    private static void addThread(List<Thread> threads, int num) {
        for (int i = 0; i < num; i++) {
            Thread t = new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        while (!Thread.interrupted()) {
                            Thread.sleep(1000);
                        }
                    } catch (InterruptedException ignored) {
                        //
                    }
                }
            });
            t.setDaemon(true);
            t.setPriority(Thread.MIN_PRIORITY);
            threads.add(t);
            t.start();
        }
    }
 
}


Добавлено через 2 минуты
По-ходу, стек для потока выделяется из heap, а не оперативной памяти.
2
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
10.04.2014, 16:05
Помогаю со студенческими работами здесь

Разработать программу, генерирующую n потоков в пуле потоков CLR
Добрый вечер. Решил поделать старые лабораторные, которые мне уже давно нужно было сдавать, но встрял на одном задании: &quot;Разработать...

Создание и завершение процессов и потоков. Приоритеты выполнения потоков
Здравствуйте. Буду очень раз если поможете понять,что конкретно нужно сделать в вот этом задании,пока особого представления о...

Замедление работы потоков если запущено несколько потоков
Есть отдельный поток который движет красным квадратом. Он каждую миллисекунду меняет положение квадрата на пиксель. Есть другой поток, он...

Синхронизация потоков на элементарном уровне (переключение потоков)
в общем разбираюсь с потоками, на сколько понял мне нужен lock Вот имеется просто пример public void RunAdd() ...

Синхронизация потоков: проблема гонки потоков
Есть проблема в синхронизации потоков, которую я не знаю, как решить. Точнее у меня получается типичная гонка потоков. Есть функция,...


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

Или воспользуйтесь поиском по форуму:
8
Ответ Создать тему
Новые блоги и статьи
Перемещение выделенных строк ТЧ из одного документа в другой
Maks 31.03.2026
Реализация из решения ниже выполнена на примере нетипового документа "ВыдачаОборудованияНаСпецтехнику" с единственной табличной частью "ОборудованиеИКомплектующие" разработанного в конфигурации КА2. . . .
Functional First Web Framework Suave
DevAlt 30.03.2026
Sauve. IO Апнулись до NET10. Из зависимостей один пакет, работает одинаково хорошо как в режиме проекта так и в интерактивном режиме. из сложностей - чисто функциональный подход. Решил. . .
Автоматическое создание документа при проведении другого документа
Maks 29.03.2026
Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .
Настройка движения справочника по регистру сведений
Maks 29.03.2026
Решение ниже реализовано на примере нетипового справочника "ТарифыМобильнойСвязи" разработанного в конфигурации КА2, с целью учета корпоративной мобильной связи в коммерческом предприятии. . . .
Автозаполнение реквизита при выборе элемента справочника
Maks 27.03.2026
Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .
Сумматор с применением элементов трёх состояний.
Hrethgir 26.03.2026
Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .
Автозаполнение реквизитов при создании документа
Maks 26.03.2026
Программный код из решения ниже размещается в модуле объекта документа, в процедуре "ПриСозданииНаСервере". Алгоритм проверки заполнения реализован для исключения перезаписи значения реквизита,. . .
Команды формы и диалоговое окно
Maks 26.03.2026
1. Команда формы "ЗаполнитьЗапчасти". Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. В качестве источника данных. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru