ThreadStress

ThreadStress.java

public class ThreadStress {

	public static class SomeRunnable implements Runnable {

		public long num = 0;
		long time;

		public SomeRunnable(int time) {
			this.time = time;
		}

		@Override
		public void run() {
			final long start = System.currentTimeMillis();
			while (System.currentTimeMillis() - start < time) {
				num++;
			}

		}

	}

	private static void test(int cantThreads) throws InterruptedException {

		SomeRunnable runnables[] = new SomeRunnable[cantThreads];
		Thread threads[] = new Thread[runnables.length];

		for (int i = 0; i < runnables.length; i++) {
			runnables[i] = new SomeRunnable(20000);
			threads[i] = new Thread(runnables[i]);
		}

		for (int i = 0; i < runnables.length; i++) {
			// System.out.println("Iniciando " + i);
			threads[i].start();
		}

		long total = 0;
		for (int i = 0; i < runnables.length; i++) {
			threads[i].join();
			// System.out.println("runnables[i].num=" + runnables[i].num);
			total += runnables[i].num;
		}

		System.out.println("Total con " + runnables.length + " threds:" + total);

	}

	public static void main(String[] args) throws InterruptedException {
		test(512);
		test(1024);
	}

}