new Thread() {
public void run() {
   System.out.println("Hi!");
}
}.start();

executor.submit(new Runnable() {
public void run() {
   System.out.println("Hi!");
});

 import java.util.concurrent.*;

    public class SpawnTest extends Thread {
        public static void main(String[] args) {
            int M = Integer.parseInt(args.length > 0 ? args[0] : "1");
            int N = Integer.parseInt(args.length > 1 ? args[1] : "1000000");
            int NpM = N / M;
            BlockingQueue queue = new LinkedBlockingQueue();
            long startTime = System.currentTimeMillis();
            for (int i = 0; i < M; i++) { new Body(queue, NpM).start(); }
            for (int i = 0; i < M; i++) { try { queue.take(); } catch (InterruptedException ie) {} }
            long stopTime = System.currentTimeMillis();
            System.out.println((NpM * M) / ((stopTime - startTime) / 1000.0));
        }

        public static class Body extends Thread {
            BlockingQueue queue;
            int count;
            public Body(BlockingQueue queue, int count) {
                this.queue = queue;
                this.count = count;
            }
            public void run() {
                if (count == 0) {
                    try { queue.put(this); } catch (InterruptedException ie) {}
                } else {
                    new Body(queue, count - 1).start();
                }
            }
        }
    }

import java.util.concurrent.*;

public class Test25 extends Thread {
    public static Executor executor;

    public static void main(String[] args) {
        int M = Integer.parseInt(args.length > 0 ? args[0] : "1");
        int N = Integer.parseInt(args.length > 1 ? args[1] : "1000000");
        executor = Executors.newFixedThreadPool(M);
        int NpM = N / M;
        BlockingQueue queue = new LinkedBlockingQueue();
        long startTime = System.currentTimeMillis();
        for (int i = 0; i < M; i++) { executor.execute(new Body(queue, NpM)); }
        for (int i = 0; i < M; i++) { try { queue.take(); } catch (InterruptedException ie) {} }
        long stopTime = System.currentTimeMillis();
        System.out.println((NpM * M) / ((stopTime - startTime) / 1000.0));
    }

    public static class Body implements Runnable {
        BlockingQueue queue;
        int count;
        public Body(BlockingQueue queue, int count) {
            this.queue = queue;
            this.count = count;
        }
        public void run() {
            if (count == 0) {
                try { queue.put(this); } catch (InterruptedException ie) {}
            } else {
                if (count % 10000 == 0) System.out.println("" + count);
                executor.execute(new Test25.Body(queue, count - 1));
            }
        }
    }
}

import java.util.concurrent.*;

public class Test25 extends Thread {
    public static Executor executor;

    public static void main(String[] args) throws InterruptedException {
        int M = Integer.parseInt(args.length > 0 ? args[0] : "1");
        int N = Integer.parseInt(args.length > 1 ? args[1] : "1000000");
        executor = Executors.newFixedThreadPool(M);
        int NpM = N / M;
        BlockingQueue queue = new ArrayBlockingQueue(1000 * 1000);
        long startTime = System.currentTimeMillis();
        for (int i = 0; i < M; i++) executor.execute(new Body(queue, NpM));
        for (int i = 0; i < N; i++) queue.take();
        long stopTime = System.currentTimeMillis();
        System.out.println((NpM * M) / ((stopTime - startTime) / 1000.0));
    }

    public static class Body implements Runnable {
        BlockingQueue queue;
        int count;
        public Body(BlockingQueue queue, int count) {
            this.queue = queue; this.count = count;
        }
        public void run() {
            try {
                for (int i = 0; i < count; i++) queue.put(this);
            } catch (InterruptedException ex) {
                ex.printStackTrace();
            }
        }
    }
}

N> executor = Executors.newFixedThreadPool(M);

N> BlockingQueue queue = new LinkedBlockingQueue();
N> long startTime = System.currentTimeMillis();
N> for (int i = 0; i < M; i++) { executor.execute(new Body(queue, NpM)); }