Распараллеливание работы между ядрами.

@Боня · Регистрация: 10.06.2010

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

Кто знает подскажите пожалуйсто.
Есть программа на java, с использованием потоков. И есть компьютер 2-х, 4-х ядерный.
Меня интересует могули я явно распределить две функции на разные ядра.
Т.е. функцию №1 просчитывает одно ядро, функцию №2 просчитывает второе ядро.
Или всё это работает в автомате, по мере загруженности? Если да, под какой операционной системой лучше?

@lenin133 · 15.12.2010, 15:21

Посмотри класс Thread, есть такая тема в топике, может это то, что ты ищешь?

Добавлено через 2 минуты
Если точнее "наследник класса Thread" Наследник класса Thread

@deadlock · 15.12.2010, 15:24

"руками" раскидать программные потоки на ядра/потоки процессора можно, почитай что такое Affinity Mask - это маска, которой награждает ОС каждый программный поток указывая на каком виртуальном процессоре ему выполняться, ее можно указывать и самому. а ОС, ОС - по вкусу )))

@Skipy · 15.12.2010, 17:14

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

почитай что такое Affinity Mask - это маска, которой награждает ОС каждый программный поток указывая на каком виртуальном процессоре ему выполняться, ее можно указывать и самому.

И как ее выставлять средствами Java?

@deadlock · 20.12.2010, 08:53

что в сети нашел:

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
import junit.framework.TestCase;
 
import com.jniwrapper.Function;
import com.jniwrapper.Int32;
import com.jniwrapper.LongInt;
import com.jniwrapper.Parameter;
import com.jniwrapper.Pointer;
import com.jniwrapper.win32.Handle;
import com.jniwrapper.win32.system.Kernel32;
 
public class TestAffinity extends TestCase {
 
    public void testGetProcessList() {
        long pid = Kernel32.getCurrentProcessId();
        System.out.println("current pid:"+pid);
        
        // Function openProcess = Kernel32.getInstance().getFunction("OpenProcess");
        Function getCurrentProcess = Kernel32.getInstance().getFunction("GetCurrentProcess");
        Function getAffinity = Kernel32.getInstance().getFunction("GetProcessAffinityMask");
        Function setAffinity = Kernel32.getInstance().getFunction("SetProcessAffinityMask");
        
        // Handle openedProcess = new Handle();
        // openProcess.invoke(openedProcess,new Parameter[]{new Int32(0x0200),new Int32(0),new LongInt(pid)});
        // openProcess.invoke(openedProcess,new Parameter[]{new Int32(0x1F0FFF),new Int32(0),new LongInt(pid)});
        // System.out.printf("open process handle: 0x%x\n",openedProcess.getValue());
        
        Handle currentProcess = new Handle(0x123);
        getCurrentProcess.invoke(currentProcess);
        
        Int32 rc = new Int32();
        Int32 sa = new Int32();
        Int32 pa = new Int32();
        getAffinity.invoke(rc,new Parameter[]{currentProcess,new Pointer(pa),new Pointer(sa)});
        System.out.printf("get process affinity mask result: %s\n",getResult(rc));
        System.out.printf("current system affinity mask: 0x%x\n",sa.getValue());
        System.out.printf("process affinity mask: :0x%x\n",pa.getValue());
        if( rc.getValue() != 1 ) {
            System.out.printf("ERROR: %d\n",getLastError());
        }
        
        pa.setValue(0x1); // first processor only
//        setAffinity.invoke(rc,new Parameter[]{openedProcess,new Pointer(pa)});
//        System.out.printf("set affinity mask result: %s\n",getResult(rc));
//        if( rc.getValue() != 1 ) {
//          System.out.printf("ERROR: %d\n",getLastError());
//        } 
        setAffinity.invoke(rc,new Parameter[]{currentProcess,pa});
        System.out.printf("set affinity mask result: %s\n",getResult(rc));
        if( rc.getValue() != 1 ) {
            System.out.printf("ERROR: %d\n",getLastError());
        } 
        
        getAffinity.invoke(rc,new Parameter[]{currentProcess,new Pointer(pa),new Pointer(sa)});
        System.out.printf("get process affinity mask result: %s\n",getResult(rc));
        System.out.printf("current system affinity mask: 0x%x\n",sa.getValue());
        System.out.printf("process affinity mask: :0x%x\n",pa.getValue());
        if( rc.getValue() != 1 ) {
            System.out.printf("ERROR: %d\n",getLastError());
        }
    }
    
    
    private String getResult(Int32 code) {
        if( code.getValue() == 0 ) return "FAILED"; 
        return "OK";
    }
 
 
    public static int getLastError()
    {
        Function function = Kernel32.getInstance().getFunction("GetLastError");
        Int32 int32 = new Int32();
        function.invoke(int32);
        return (int)int32.getValue();
    }
    
}

@Skipy · 20.12.2010, 11:52

Это НЕ Java. Это JNI.

Новые блоги и статьи Все статьи Все блоги /
Модель заражения группы наркоманов alhaos 17.04.2026 Условия задачи сформулированы тут Суть: - Группа наркоманов из 10 человек. - Только один инфицирован ВИЧ. - Колются одной иглой. - Колются раз в день. - Колются последовательно через. . .	Мысли в слух. Про "навсегда". kumehtar 16.04.2026 Подумалось тут, что наверное очень глупо использовать во всяких своих установках понятие "навсегда". Это очень сильное понятие, и я только начинаю понимать край его смысла, не смотря на то что давно. . .	My Business CRM MaGz GoLd 16.04.2026 Всем привет, недавно возникла потребность создать CRM, для личных нужд. Собственно программа предоставляет из себя базу данных клиентов, в которой можно фиксировать звонки, стадии сделки, а также. . .	Знаешь почему 90% людей редко бывают счастливыми? kumehtar 14.04.2026 Потому что они ждут. Ждут выходных, ждут отпуска, ждут удачного момента. . . а удачный момент так и не приходит.
Фиксация колонок в отчете СКД Maks 14.04.2026 Фиксация колонок в СКД отчета типа Таблица. Задача: зафиксировать три левых колонки в отчете. Процедура ПриКомпоновкеРезультата(ДокументРезультат, ДанныеРасшифровки, СтандартнаяОбработка) / / . . .	Настройки VS Code Loafer 13.04.2026 { "cmake. configureOnOpen": false, "diffEditor. ignoreTrimWhitespace": true, "editor. guides. bracketPairs": "active", "extensions. ignoreRecommendations": true, . . .	Оптимизация кода на разграничение прав доступа к элементам формы Maks 13.04.2026 Алгоритм из решения ниже реализован на нетиповом документе, разработанного в конфигурации КА2. Задачи, как таковой, поставлено не было, проделанное ниже исключительно моя инициатива. Было так:. . .	Контроль заполнения и очистка дат в зависимости от значения перечислений Maks 12.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: реализовать контроль корректности заполнения дат назначения. . .

@Боня 0 / 0 / 0 Регистрация: 10.06.2010 Сообщений: 17

	Распараллеливание работы между ядрами. 10.12.2010, 23:04. Показов 2724. Ответов 5 Метки нет (Все метки) Кто знает подскажите пожалуйсто. Есть программа на java, с использованием потоков. И есть компьютер 2-х, 4-х ядерный. Меня интересует могули я явно распределить две функции на разные ядра. Т.е. функцию №1 просчитывает одно ядро, функцию №2 просчитывает второе ядро. Или всё это работает в автомате, по мере загруженности? Если да, под какой операционной системой лучше? 0

@lenin133 6 / 6 / 0 Регистрация: 24.11.2010 Сообщений: 25
	15.12.2010, 15:21
	Посмотри класс Thread, есть такая тема в топике, может это то, что ты ищешь? Добавлено через 2 минуты Если точнее "наследник класса Thread" Наследник класса Thread 0

@deadlock 378 / 358 / 23 Регистрация: 14.12.2010 Сообщений: 1,265
	15.12.2010, 15:24
	"руками" раскидать программные потоки на ядра/потоки процессора можно, почитай что такое Affinity Mask - это маска, которой награждает ОС каждый программный поток указывая на каком виртуальном процессоре ему выполняться, ее можно указывать и самому. а ОС, ОС - по вкусу ))) 0

@Skipy 2000 / 1427 / 92 Регистрация: 25.11.2010 Сообщений: 3,611
	20.12.2010, 11:52
	Это НЕ Java. Это JNI. 0