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

@Боня · Регистрация: 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.

Новые блоги и статьи Все статьи Все блоги /
Конвертировать закладки 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. На борту пять. . .	Символьное дифференцирование igorrr37 13.02.2026 / * Программа принимает математическое выражение в виде строки и выдаёт его производную в виде строки и вычисляет значение производной при заданном х Логарифм записывается как: (x-2)log(x^2+2) -. . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу zbw 12.02.2026 И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.	«Знание-Сила» zbw 12.02.2026 «Знание-Сила» «Время-Деньги» «Деньги -Пуля»	SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 12.02.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .	SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 11.02.2026 Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .

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

	Распараллеливание работы между ядрами. 10.12.2010, 23:04. Показов 2674. Ответов 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