/* * Copyright (c) 2018, Google and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. * * This code is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License * version 2 for more details (a copy is included in the LICENSE file that * accompanied this code). * * You should have received a copy of the GNU General Public License version * 2 along with this work; if not, write to the Free Software Foundation, * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. * * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA * or visit www.oracle.com if you need additional information or have any * questions. */ package MyPackage; import java.util.ArrayList; import java.util.List; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; /** API for handling heap allocating threads. */ class ThreadInformation { private Thread thread; private BlockingQueue waitingQueue; private Allocator allocator; public ThreadInformation(Thread thread, BlockingQueue waitingQueue, Allocator allocator) { this.thread = thread; this.waitingQueue = waitingQueue; this.allocator = allocator; } public void waitForToken() { allocator.waitForToken(); } public void stop() { try { allocator.stopRun(); thread.join(); if (!allocator.endedNormally()) { throw new RuntimeException("Thread did not end normally..."); } } catch(InterruptedException e) { throw new RuntimeException("Thread got interrupted..."); } } private void start() { allocator.start(); } public static void startThreads(List threadList) { for (ThreadInformation info : threadList) { info.start(); } } public static void stopThreads(List threadList) { for (ThreadInformation info : threadList) { info.stop(); } } public Thread getThread() { return thread; } public static void waitForThreads(List threadList) { // Wait until all threads have put an object in the queue. for (ThreadInformation info : threadList) { info.waitForToken(); } } public static List createThreadList(int numThreads) { List threadList = new ArrayList<>(); for (int i = 0 ; i < numThreads; i++) { BlockingQueue queue = new LinkedBlockingQueue<>(); Allocator allocator = new Allocator(i, queue); Thread thread = new Thread(allocator, "Allocator" + i); ThreadInformation info = new ThreadInformation(thread, queue, allocator); threadList.add(info); thread.start(); } return threadList; } } class Allocator implements Runnable { private int depth; private List currentList; private BlockingQueue waitingQueue; private BlockingQueue jobCanStop; private boolean failed; public Allocator(int depth, BlockingQueue waitingQueue) { jobCanStop = new LinkedBlockingQueue<>(); this.waitingQueue = waitingQueue; this.depth = depth; } public boolean endedNormally() { return !failed; } private void helper() { List newList = new ArrayList<>(); // Let us assume that the array is 24 bytes of memory, by default we sample at 512k, keep in // memory at least 2MB without counting the link-list itself, which adds to this. int iterations = (1 << 21) / 24; for (int i = 0; i < iterations; i++) { int newTmp[] = new int[1]; // Force it to be kept. newList.add(newTmp); } // Replace old list with new list, which provokes two things: // Old list will get GC'd at some point. // New list forces that this thread has some allocations still sampled. currentList = newList; } private void recursiveWrapper(int depth) { if (depth > 0) { recursiveWrapper(depth - 1); } helper(); } public void stopRun() throws InterruptedException { jobCanStop.put(new Object()); } public void run() { // Wait till we are told to really start. waitForToken(); for (int j = 0; j < 50; j++) { recursiveWrapper(depth); } System.err.println("Here done allocating"); try { // Tell the main thread we are done. waitingQueue.put(new Object()); System.err.println("Waited for queue"); // Wait until the main thread says we can stop. jobCanStop.take(); } catch (InterruptedException e) { failed = true; } System.err.println("Done !!!!"); } public void waitForToken() { try { waitingQueue.take(); } catch(InterruptedException e) { throw new RuntimeException("Thread got interrupted..."); } } public void start() { try { waitingQueue.put(new Object()); } catch(InterruptedException e) { throw new RuntimeException("Thread got interrupted..."); } } }