@@ -0,0 +1,591 @@
+package pw.koj.jetstreem.core;%0A%0Apublic class StrmCore %7B%0A    private int numOfCpu;%0A    private int numOfThreads;%0A%0A    public int threadCount() %7B%0A        String s = System.getenv(%22STRM_THREAD_MAX%22);%0A        if (s != null) %7B%0A            try %7B%0A                int n;%0A                n = Integer.parseInt(s);%0A                if (n %3E 0) return n;%0A            %7D catch (NumberFormatException ex) %7B%0A                System.err.println(%22env var %5C%22STRM_THREAD_MAX%5C%22 should be number%22);%0A            %7D%0A        %7D%0A        Runtime rt = Runtime.getRuntime();%0A        return rt.availableProcessors();%0A    %7D%0A%7D%0A%0A

add class StrmCore