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

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();
    }
    
}