Skip to content

Instantly share code, notes, and snippets.

@fwbrasil

fwbrasil/InterruptBench-forkKyo-alloc.html

Created June 10, 2023 08:42
Show Gist options
  • Save fwbrasil/2c44a04dfbbcb9814f15da0185cdfe84 to your computer and use it in GitHub Desktop.
Save fwbrasil/2c44a04dfbbcb9814f15da0185cdfe84 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
InterruptBench-forkKyo-alloc.html
<!DOCTYPE html>
<html lang='en'>
<head>
<meta charset='utf-8'>
<style>
body {margin: 0; padding: 10px; background-color: #ffffff}
h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center}
header {margin: -24px 0 5px 0; line-height: 24px}
button {font: 12px sans-serif; cursor: pointer}
p {margin: 5px 0 5px 0}
a {color: #0366d6}
#hl {position: absolute; display: none; overflow: hidden; white-space: nowrap; pointer-events: none; background-color: #ffffe0; outline: 1px solid #ffc000; height: 15px}
#hl span {padding: 0 3px 0 3px}
#status {overflow: hidden; white-space: nowrap}
#match {overflow: hidden; white-space: nowrap; display: none; float: right; text-align: right}
#reset {cursor: pointer}
#canvas {width: 100%; height: 640px}
</style>
</head>
<body style='font: 12px Verdana, sans-serif'>
<h1>Allocation profile</h1>
<header style='text-align: left'><button id='reverse' title='Reverse'>&#x1f53b;</button>&nbsp;&nbsp;<button id='search' title='Search'>&#x1f50d;</button></header>
<header style='text-align: right'>Produced by <a href='https://github.com/jvm-profiling-tools/async-profiler'>async-profiler</a></header>
<canvas id='canvas'></canvas>
<div id='hl'><span></span></div>
<p id='match'>Matched: <span id='matchval'></span> <span id='reset' title='Clear'>&#x274c;</span></p>
<p id='status'>&nbsp;</p>
<script>
// Copyright 2020 Andrei Pangin
// Licensed under the Apache License, Version 2.0.
'use strict';
var root, rootLevel, px, pattern;
var reverse = false;
const levels = Array(40);
for (let h = 0; h < levels.length; h++) {
levels[h] = [];
}
const canvas = document.getElementById('canvas');
const c = canvas.getContext('2d');
const hl = document.getElementById('hl');
const status = document.getElementById('status');
const canvasWidth = canvas.offsetWidth;
const canvasHeight = canvas.offsetHeight;
canvas.style.width = canvasWidth + 'px';
canvas.width = canvasWidth * (devicePixelRatio || 1);
canvas.height = canvasHeight * (devicePixelRatio || 1);
if (devicePixelRatio) c.scale(devicePixelRatio, devicePixelRatio);
c.font = document.body.style.font;
const palette = [
[0xb2e1b2, 20, 20, 20],
[0x50e150, 30, 30, 30],
[0x50cccc, 30, 30, 30],
[0xe15a5a, 30, 40, 40],
[0xc8c83c, 30, 30, 10],
[0xe17d00, 30, 30, 0],
[0xcce880, 20, 20, 20],
];
function getColor(p) {
const v = Math.random();
return '#' + (p[0] + ((p[1] * v) << 16 | (p[2] * v) << 8 | (p[3] * v))).toString(16);
}
function f(level, left, width, type, title, inln, c1, int) {
levels[level].push({left: left, width: width, color: getColor(palette[type]), title: title,
details: (int ? ', int=' + int : '') + (c1 ? ', c1=' + c1 : '') + (inln ? ', inln=' + inln : '')
});
}
function samples(n) {
return n === 1 ? '1 sample' : n.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ',') + ' samples';
}
function pct(a, b) {
return a >= b ? '100' : (100 * a / b).toFixed(2);
}
function findFrame(frames, x) {
let left = 0;
let right = frames.length - 1;
while (left <= right) {
const mid = (left + right) >>> 1;
const f = frames[mid];
if (f.left > x) {
right = mid - 1;
} else if (f.left + f.width <= x) {
left = mid + 1;
} else {
return f;
}
}
if (frames[left] && (frames[left].left - x) * px < 0.5) return frames[left];
if (frames[right] && (x - (frames[right].left + frames[right].width)) * px < 0.5) return frames[right];
return null;
}
function search(r) {
if (r === true && (r = prompt('Enter regexp to search:', '')) === null) {
return;
}
pattern = r ? RegExp(r) : undefined;
const matched = render(root, rootLevel);
document.getElementById('matchval').textContent = pct(matched, root.width) + '%';
document.getElementById('match').style.display = r ? 'inherit' : 'none';
}
function render(newRoot, newLevel) {
if (root) {
c.fillStyle = '#ffffff';
c.fillRect(0, 0, canvasWidth, canvasHeight);
}
root = newRoot || levels[0][0];
rootLevel = newLevel || 0;
px = canvasWidth / root.width;
const x0 = root.left;
const x1 = x0 + root.width;
const marked = [];
function mark(f) {
return marked[f.left] >= f.width || (marked[f.left] = f.width);
}
function totalMarked() {
let total = 0;
let left = 0;
Object.keys(marked).sort(function(a, b) { return a - b; }).forEach(function(x) {
if (+x >= left) {
total += marked[x];
left = +x + marked[x];
}
});
return total;
}
function drawFrame(f, y, alpha) {
if (f.left < x1 && f.left + f.width > x0) {
c.fillStyle = pattern && f.title.match(pattern) && mark(f) ? '#ee00ee' : f.color;
c.fillRect((f.left - x0) * px, y, f.width * px, 15);
if (f.width * px >= 21) {
const chars = Math.floor(f.width * px / 7);
const title = f.title.length <= chars ? f.title : f.title.substring(0, chars - 2) + '..';
c.fillStyle = '#000000';
c.fillText(title, Math.max(f.left - x0, 0) * px + 3, y + 12, f.width * px - 6);
}
if (alpha) {
c.fillStyle = 'rgba(255, 255, 255, 0.5)';
c.fillRect((f.left - x0) * px, y, f.width * px, 15);
}
}
}
for (let h = 0; h < levels.length; h++) {
const y = reverse ? h * 16 : canvasHeight - (h + 1) * 16;
const frames = levels[h];
for (let i = 0; i < frames.length; i++) {
drawFrame(frames[i], y, h < rootLevel);
}
}
return totalMarked();
}
canvas.onmousemove = function() {
const h = Math.floor((reverse ? event.offsetY : (canvasHeight - event.offsetY)) / 16);
if (h >= 0 && h < levels.length) {
const f = findFrame(levels[h], event.offsetX / px + root.left);
if (f) {
if (f != root) getSelection().removeAllRanges();
hl.style.left = (Math.max(f.left - root.left, 0) * px + canvas.offsetLeft) + 'px';
hl.style.width = (Math.min(f.width, root.width) * px) + 'px';
hl.style.top = ((reverse ? h * 16 : canvasHeight - (h + 1) * 16) + canvas.offsetTop) + 'px';
hl.firstChild.textContent = f.title;
hl.style.display = 'block';
canvas.title = f.title + '\n(' + samples(f.width) + f.details + ', ' + pct(f.width, levels[0][0].width) + '%)';
canvas.style.cursor = 'pointer';
canvas.onclick = function() {
if (f != root) {
render(f, h);
canvas.onmousemove();
}
};
status.textContent = 'Function: ' + canvas.title;
return;
}
}
canvas.onmouseout();
}
canvas.onmouseout = function() {
hl.style.display = 'none';
status.textContent = '\xa0';
canvas.title = '';
canvas.style.cursor = '';
canvas.onclick = '';
}
canvas.ondblclick = function() {
getSelection().selectAllChildren(hl);
}
document.getElementById('reverse').onclick = function() {
reverse = !reverse;
render();
}
document.getElementById('search').onclick = function() {
search(true);
}
document.getElementById('reset').onclick = function() {
search(false);
}
window.onkeydown = function() {
if (event.ctrlKey && event.keyCode === 70) {
event.preventDefault();
search(true);
} else if (event.keyCode === 27) {
search(false);
}
}
f(0,0,11300,3,'all')
f(1,0,11297,1,'java/lang/Thread.run')
f(2,0,11297,1,'java/util/concurrent/ThreadPoolExecutor$Worker.run')
f(3,0,11297,1,'java/util/concurrent/ThreadPoolExecutor.runWorker')
f(4,0,2021,1,'java/util/concurrent/FutureTask.run')
f(5,0,2021,1,'java/util/concurrent/Executors$RunnableAdapter.call')
f(6,0,2021,1,'java/util/concurrent/FutureTask.run')
f(7,0,2021,1,'org/openjdk/jmh/runner/BenchmarkHandler$BenchmarkTask.call')
f(8,0,2021,1,'org/openjdk/jmh/runner/BenchmarkHandler$BenchmarkTask.call')
f(9,0,2021,1,'java/lang/reflect/Method.invoke')
f(10,0,2021,1,'jdk/internal/reflect/DelegatingMethodAccessorImpl.invoke')
f(11,0,2021,1,'jdk/internal/reflect/NativeMethodAccessorImpl.invoke')
f(12,0,2021,1,'jdk/internal/reflect/NativeMethodAccessorImpl.invoke0')
f(13,0,2021,1,'kyo/bench/jmh_generated/InterruptBench_forkKyo_jmhTest.forkKyo_Throughput')
f(14,0,2020,1,'kyo/bench/jmh_generated/InterruptBench_forkKyo_jmhTest.forkKyo_thrpt_jmhStub')
f(15,0,2020,1,'kyo/bench/Bench.forkKyo')
f(16,0,33,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(17,0,33,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(18,0,33,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(19,0,33,2,'kyo.bench.Bench$$Lambda$37+0x0000000800c3abb8')
f(16,33,1391,1,'kyo/bench/Bench.runLoop$2')
f(17,33,865,1,'kyo/concurrent/fibers$Fiber$$anon$10.apply')
f(18,33,865,1,'kyo/concurrent/fibers$Fiber$$anon$10.apply')
f(19,33,865,1,'kyo/concurrent/scheduler/IOPromise.block')
f(20,33,865,1,'kyo/concurrent/scheduler/IOPromise.loop$4')
f(21,33,492,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.acquireSharedInterruptibly')
f(22,33,492,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.acquire')
f(23,33,173,2,'java.util.concurrent.locks.AbstractQueuedSynchronizer$SharedNode')
f(23,206,319,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.tryInitializeHead')
f(24,206,319,2,'java.util.concurrent.locks.AbstractQueuedSynchronizer$ExclusiveNode')
f(21,525,118,2,'kyo.concurrent.scheduler.IOPromise$$anon$1')
f(21,643,255,1,'kyo/concurrent/scheduler/IOPromise.loop$5')
f(22,643,255,1,'kyo/concurrent/scheduler/IOPromise$Pending.add')
f(23,643,255,2,'kyo.concurrent.scheduler.IOPromise$Pending$$anon$3')
f(17,898,526,1,'kyo/core$$anon$5.apply')
f(18,898,459,1,'kyo/core$$anon$5.apply')
f(19,898,459,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(20,898,459,1,'kyo/concurrent/fibers$Fibers$$Lambda$38.0x0000000800c3e600.apply')
f(21,898,459,1,'kyo/concurrent/fibers$Fibers.forkFiber$$anonfun$1')
f(22,898,152,2,'kyo.concurrent.fibers$Fibers$$anon$29')
f(22,1050,212,2,'kyo.concurrent.scheduler.IOTask')
f(22,1262,95,1,'kyo/concurrent/fibers$Fiber$.promise')
f(23,1262,95,2,'kyo.concurrent.fibers$Fiber')
f(18,1357,67,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(19,1357,67,1,'kyo/bench/Bench$$Lambda$39.0x0000000800c81f98.apply')
f(20,1357,67,1,'kyo/bench/Bench.$anonfun$2')
f(21,1357,67,1,'kyo/concurrent/fibers$Fiber.block')
f(22,1357,67,2,'kyo.concurrent.fibers$Fiber$$anon$10')
f(16,1424,473,1,'kyo/concurrent/fibers$Fibers.forkFiber')
f(17,1424,135,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(18,1424,135,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(19,1424,135,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(20,1424,135,2,'kyo.concurrent.fibers$Fibers$$Lambda$38+0x0000000800c3e600')
f(17,1559,44,1,'kyo/locals$Locals$.save')
f(18,1559,44,2,'kyo.locals$Locals$$anon$2')
f(17,1603,294,1,'kyo/package$KyoOps$.map$extension')
f(18,1603,294,1,'kyo/package$KyoOps$.flatMap$extension')
f(19,1603,294,1,'kyo/core$.transform')
f(20,1603,294,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(21,1603,294,2,'kyo.core$$anon$5')
f(16,1897,123,1,'kyo/package$KyoOps$.flatMap$extension')
f(17,1897,123,1,'kyo/core$.transform')
f(18,1897,123,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(19,1897,123,2,'kyo.core$$anon$5')
f(14,2020,1,1,'org/openjdk/jmh/results/ThroughputResult.<init>')
f(15,2020,1,1,'java/lang/StringBuilder.toString')
f(16,2020,1,1,'java/lang/StringLatin1.newString')
f(17,2020,1,2,'java.lang.String')
f(4,2021,11,1,'kyo/concurrent/scheduler/Coordinator$$$Lambda$49.0x0000000800d1d0e8.run')
f(5,2021,11,1,'kyo/concurrent/scheduler/Coordinator$.$init$$$anonfun$1')
f(6,2021,11,1,'kyo/concurrent/scheduler/Coordinator$.update')
f(7,2021,10,1,'java/util/concurrent/ThreadPoolExecutor.execute')
f(8,2021,10,1,'java/util/concurrent/SynchronousQueue.offer')
f(9,2021,10,1,'java/util/concurrent/SynchronousQueue$TransferStack.transfer')
f(10,2021,10,1,'java/util/concurrent/SynchronousQueue$TransferStack.snode')
f(11,2021,10,2,'java.util.concurrent.SynchronousQueue$TransferStack$SNode')
f(7,2031,1,1,'kyo/concurrent/scheduler/MovingStdDev.observe')
f(8,2031,1,2,'java.lang.String')
f(4,2032,11,1,'kyo/concurrent/scheduler/Coordinator$$$Lambda$50.0x0000000800d1d310.run')
f(5,2032,11,1,'kyo/concurrent/scheduler/Coordinator$.$init$$$anonfun$2')
f(6,2032,11,1,'kyo/concurrent/scheduler/Scheduler$.cycle')
f(7,2032,11,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(8,2032,11,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(9,2032,11,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(10,2032,11,1,'jdk/internal/misc/Unsafe.allocateInstance')
f(11,2032,11,2,'kyo.concurrent.scheduler.Scheduler$$$Lambda$68+0x0000000800d48f78')
f(4,2043,9254,1,'kyo/concurrent/scheduler/Scheduler$$$Lambda$52.0x0000000800d1ba80.run')
f(5,2043,9254,1,'kyo/concurrent/scheduler/Scheduler$.startWorkers$$anonfun$1')
f(6,2043,9254,1,'kyo/concurrent/scheduler/Worker.runWorker')
f(7,2043,8767,1,'kyo/concurrent/scheduler/IOTask.run')
f(8,2043,8767,1,'kyo/concurrent/scheduler/IOTask.eval')
f(9,2043,4,1,'kyo/concurrent/fibers$Fibers$$anon$29.apply')
f(10,2043,4,1,'kyo/concurrent/fibers$Fibers$$anon$29.apply')
f(11,2043,4,1,'kyo/bench/Bench$$Lambda$37.0x0000000800c3abb8.apply')
f(12,2043,4,1,'kyo/bench/Bench.$anonfun$1')
f(13,2043,4,1,'kyo/bench/InterruptBench.kyoBenchFiber')
f(14,2043,4,1,'kyo/bench/InterruptBench.iterate$2')
f(15,2043,3,1,'kyo/concurrent/fibers$Fibers.forkFiber')
f(16,2043,1,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(17,2043,1,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(18,2043,1,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(19,2043,1,2,'kyo.concurrent.fibers$Fibers$$Lambda$38+0x0000000800c3e600')
f(16,2044,1,1,'kyo/locals$Locals$.save')
f(17,2044,1,2,'kyo.locals$Locals$$anon$2')
f(16,2045,1,1,'kyo/package$KyoOps$.map$extension')
f(17,2045,1,1,'kyo/package$KyoOps$.flatMap$extension')
f(18,2045,1,1,'kyo/core$.transform')
f(19,2045,1,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(20,2045,1,2,'kyo.core$$anon$5')
f(15,2046,1,1,'kyo/package$KyoOps$.flatMap$extension')
f(16,2046,1,1,'kyo/core$.transform')
f(17,2046,1,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(18,2046,1,2,'kyo.core$$anon$5')
f(9,2047,3364,1,'kyo/concurrent/scheduler/IOTask.finalize$1')
f(10,2047,3364,1,'kyo/concurrent/fibers$Fiber$$anon$11$$Lambda$60.0x0000000800d435d0.apply$mcV$sp')
f(11,2047,3364,1,'kyo/concurrent/fibers$.kyo$concurrent$fibers$Fiber$$anon$11$$_$apply$$anonfun$1')
f(12,2047,3364,1,'kyo/concurrent/fibers$.loop$9')
f(13,2047,3364,1,'kyo/concurrent/scheduler/IOPromise.kyo$concurrent$scheduler$IOPromise$$inline$complete')
f(14,2047,3364,1,'kyo/concurrent/scheduler/IOPromise.complete')
f(15,2047,3364,1,'kyo/concurrent/scheduler/IOPromise$Pending.flush')
f(16,2047,3364,1,'kyo/concurrent/scheduler/IOPromise$Pending.loop$7')
f(17,2047,3364,1,'kyo/concurrent/scheduler/IOPromise$Pending$$anon$3.run')
f(18,2047,3364,1,'scala/runtime/function/JProcedure1.apply')
f(19,2047,3364,1,'scala/runtime/function/JProcedure1.apply')
f(20,2047,3364,1,'kyo/concurrent/scheduler/IOTask$$Lambda$66.0x0000000800d487a0.applyVoid')
f(21,2047,3364,1,'kyo/concurrent/scheduler/IOTask.loop$5$$anonfun$1')
f(22,2047,270,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(23,2047,270,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(24,2047,270,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(25,2047,270,2,'kyo.concurrent.scheduler.IOTask$$Lambda$67+0x0000000800d48ba8')
f(22,2317,626,2,'kyo.concurrent.scheduler.IOTask')
f(22,2943,389,1,'kyo/concurrent/scheduler/IOPromise.become')
f(23,2943,389,1,'kyo/concurrent/scheduler/IOPromise.loop$3')
f(24,2943,117,1,'kyo/concurrent/scheduler/IOPromise$Linked$.apply')
f(25,2943,117,2,'kyo.concurrent.scheduler.IOPromise$Linked')
f(24,3060,272,1,'kyo/concurrent/scheduler/IOPromise.merge')
f(25,3060,272,1,'kyo/concurrent/scheduler/IOPromise.loop$2')
f(26,3060,272,1,'kyo/concurrent/scheduler/IOPromise$Pending.merge')
f(27,3060,272,2,'kyo.concurrent.scheduler.IOPromise$Pending$$anon$5')
f(22,3332,2079,1,'kyo/package$KyoOps$.map$extension')
f(23,3332,2079,1,'kyo/package$KyoOps$.flatMap$extension')
f(24,3332,2079,1,'kyo/core$.transform')
f(25,3332,2079,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(26,3332,2079,1,'kyo/concurrent/scheduler/IOTask$$Lambda$67.0x0000000800d48ba8.apply')
f(27,3332,2079,1,'kyo/concurrent/scheduler/IOTask.$anonfun$1')
f(28,3332,2079,1,'kyo/core$$anon$5.apply')
f(29,3332,2079,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(30,3332,2079,1,'kyo/bench/InterruptBench$$Lambda$58.0x0000000800d42ae0.apply')
f(31,3332,2079,1,'kyo/bench/InterruptBench.iterate$2$$anonfun$adapted$1')
f(32,3332,2079,1,'kyo/bench/InterruptBench.iterate$2$$anonfun$3')
f(33,3332,2079,1,'kyo/bench/InterruptBench.iterate$2')
f(34,3332,479,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(35,3332,265,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(36,3332,265,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(37,3332,265,2,'kyo.bench.InterruptBench$$Lambda$56+0x0000000800d46eb0')
f(35,3597,214,1,'java/lang/invoke/LambdaForm$DMH.0x0000000800d40400.newInvokeSpecial')
f(36,3597,214,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(37,3597,214,2,'kyo.bench.InterruptBench$$Lambda$58+0x0000000800d42ae0')
f(34,3811,738,1,'kyo/concurrent/fibers$Fibers.forkFiber')
f(35,3811,250,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(36,3811,250,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(37,3811,250,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(38,3811,250,2,'kyo.concurrent.fibers$Fibers$$Lambda$38+0x0000000800c3e600')
f(35,4061,141,1,'kyo/locals$Locals$.save')
f(36,4061,141,2,'kyo.locals$Locals$$anon$2')
f(35,4202,347,1,'kyo/package$KyoOps$.map$extension')
f(36,4202,347,1,'kyo/package$KyoOps$.flatMap$extension')
f(37,4202,347,1,'kyo/core$.transform')
f(38,4202,347,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(39,4202,347,2,'kyo.core$$anon$5')
f(34,4549,862,1,'kyo/package$KyoOps$.flatMap$extension')
f(35,4549,862,1,'kyo/core$.transform')
f(36,4549,862,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(37,4549,862,2,'kyo.core$$anon$5')
f(9,5411,469,1,'kyo/concurrent/scheduler/IOTask.loop$2')
f(10,5411,217,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(11,5411,217,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(12,5411,217,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(13,5411,217,2,'kyo.concurrent.scheduler.IOTask$$Lambda$62+0x0000000800d41a18')
f(10,5628,252,1,'kyo/concurrent/scheduler/IOPromise$Pending.add')
f(11,5628,252,2,'kyo.concurrent.scheduler.IOPromise$Pending$$anon$3')
f(9,5880,553,1,'kyo/concurrent/scheduler/IOTask.loop$5')
f(10,5880,270,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(11,5880,270,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(12,5880,270,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(13,5880,270,2,'kyo.concurrent.scheduler.IOTask$$Lambda$66+0x0000000800d487a0')
f(10,6150,283,1,'kyo/concurrent/scheduler/IOPromise$Pending.add')
f(11,6150,283,2,'kyo.concurrent.scheduler.IOPromise$Pending$$anon$3')
f(9,6433,4377,1,'kyo/core$$anon$5.apply')
f(10,6433,1302,1,'kyo/concurrent/fibers$Fiber$$anon$11.apply')
f(11,6433,1302,1,'kyo/concurrent/fibers$Fiber$$anon$11.apply')
f(12,6433,440,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(13,6433,440,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(14,6433,440,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(15,6433,233,2,'kyo.concurrent.fibers$Fiber$$anon$11$$Lambda$60+0x0000000800d435d0')
f(15,6666,207,2,'kyo.concurrent.fibers$Fiber$$anon$11$$Lambda$61+0x0000000800d43ae0')
f(12,6873,317,2,'kyo.concurrent.scheduler.IOPromise')
f(12,7190,201,1,'kyo/concurrent/fibers$Fiber.interrupt')
f(13,7190,201,2,'kyo.concurrent.fibers$Fiber$$anon$12')
f(12,7391,344,1,'kyo/package$KyoOps$.map$extension')
f(13,7391,344,1,'kyo/package$KyoOps$.flatMap$extension')
f(14,7391,344,1,'kyo/core$.transform')
f(15,7391,344,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(16,7391,344,2,'kyo.core$$anon$5')
f(10,7735,1940,1,'kyo/core$$anon$5.apply')
f(11,7735,171,1,'kyo/concurrent/fibers$Fiber$$anon$12.apply')
f(12,7735,171,1,'kyo/concurrent/fibers$Fiber$$anon$12.apply')
f(13,7735,171,1,'kyo/concurrent/fibers$Fiber$$anon$12.loop$10')
f(14,7735,171,2,'kyo.concurrent.fibers$Fiber$$anon$12$$anon$13')
f(11,7906,968,1,'kyo/core$$anon$5.apply')
f(12,7906,968,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(13,7906,968,1,'kyo/concurrent/fibers$Fibers$$Lambda$38.0x0000000800c3e600.apply')
f(14,7906,968,1,'kyo/concurrent/fibers$Fibers.forkFiber$$anonfun$1')
f(15,7906,209,2,'kyo.concurrent.fibers$Fibers$$anon$29')
f(15,8115,571,2,'kyo.concurrent.scheduler.IOTask')
f(15,8686,188,1,'kyo/concurrent/fibers$Fiber$.promise')
f(16,8686,188,2,'kyo.concurrent.fibers$Fiber')
f(11,8874,801,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(12,8874,310,1,'kyo/bench/InterruptBench$$Lambda$57.0x0000000800d47a30.apply')
f(13,8874,310,1,'kyo/bench/InterruptBench.iterate$2$$anonfun$2')
f(14,8874,310,1,'kyo/concurrent/fibers$Fiber.interruptAwait')
f(15,8874,310,1,'kyo/concurrent/fibers$Fiber.interruptAwait')
f(16,8874,310,2,'kyo.concurrent.fibers$Fiber$$anon$11')
f(12,9184,491,1,'kyo/concurrent/fibers$Fiber$$anon$11$$Lambda$61.0x0000000800d43ae0.apply')
f(13,9184,491,1,'kyo/concurrent/fibers$.kyo$concurrent$fibers$Fiber$$anon$11$$_$apply$$anonfun$adapted$1')
f(14,9184,491,1,'kyo/concurrent/fibers$.apply$$anonfun$2')
f(15,9184,167,2,'kyo.concurrent.fibers$Fiber')
f(15,9351,324,1,'kyo/concurrent/fibers$Fiber.join')
f(16,9351,324,1,'kyo/concurrent/fibers$Fibers.get')
f(17,9351,324,1,'kyo/concurrent/fibers$Fibers.suspend')
f(18,9351,324,1,'kyo/core$Effect.suspend$')
f(19,9351,324,1,'kyo/core$Effect.suspend')
f(20,9351,324,1,'kyo/core$Effect.kyo$core$Effect$$_$suspendLoop$1')
f(21,9351,324,2,'kyo.core$Effect$$anon$2')
f(10,9675,1135,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(11,9675,1135,2,'kyo.core$$anon$5')
f(7,10810,487,1,'kyo/concurrent/scheduler/Queue.poll')
f(8,10810,487,1,'java/lang/invoke/Invokers$Holder.linkToTargetMethod')
f(9,10810,487,1,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial')
f(10,10810,487,1,'java/lang/invoke/DirectMethodHandle.allocateInstance')
f(11,10810,487,2,'kyo.concurrent.scheduler.Queue$$Lambda$55+0x0000000800d46330')
f(1,11297,3,1,'org/openjdk/jmh/runner/ForkedMain.main')
f(2,11297,3,1,'org/openjdk/jmh/runner/ForkedRunner.run')
f(3,11297,3,1,'org/openjdk/jmh/runner/BaseRunner.runBenchmarksForked')
f(4,11297,3,1,'org/openjdk/jmh/runner/BaseRunner.doSingle')
f(5,11297,3,1,'org/openjdk/jmh/runner/BaseRunner.runBenchmark')
f(6,11297,3,1,'org/openjdk/jmh/runner/BaseRunner.runBenchmark')
f(7,11297,3,1,'org/openjdk/jmh/runner/BenchmarkHandler.runIteration')
f(8,11297,3,1,'org/openjdk/jmh/runner/InfraControl.awaitWarmdownReady')
f(9,11297,3,1,'org/openjdk/jmh/runner/InfraControlL2.awaitWarmdownReady')
f(10,11297,3,1,'java/util/concurrent/CountDownLatch.await')
f(11,11297,3,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.acquireSharedInterruptibly')
f(12,11297,3,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.acquire')
f(13,11297,3,2,'java.util.concurrent.locks.AbstractQueuedSynchronizer$SharedNode')
search();
</script></body></html>
Raw
InterruptBench-forkKyo-cpu.html
<!DOCTYPE html>
<html lang='en'>
<head>
<meta charset='utf-8'>
<style>
body {margin: 0; padding: 10px; background-color: #ffffff}
h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center}
header {margin: -24px 0 5px 0; line-height: 24px}
button {font: 12px sans-serif; cursor: pointer}
p {margin: 5px 0 5px 0}
a {color: #0366d6}
#hl {position: absolute; display: none; overflow: hidden; white-space: nowrap; pointer-events: none; background-color: #ffffe0; outline: 1px solid #ffc000; height: 15px}
#hl span {padding: 0 3px 0 3px}
#status {overflow: hidden; white-space: nowrap}
#match {overflow: hidden; white-space: nowrap; display: none; float: right; text-align: right}
#reset {cursor: pointer}
#canvas {width: 100%; height: 624px}
</style>
</head>
<body style='font: 12px Verdana, sans-serif'>
<h1>CPU profile</h1>
<header style='text-align: left'><button id='reverse' title='Reverse'>&#x1f53b;</button>&nbsp;&nbsp;<button id='search' title='Search'>&#x1f50d;</button></header>
<header style='text-align: right'>Produced by <a href='https://github.com/jvm-profiling-tools/async-profiler'>async-profiler</a></header>
<canvas id='canvas'></canvas>
<div id='hl'><span></span></div>
<p id='match'>Matched: <span id='matchval'></span> <span id='reset' title='Clear'>&#x274c;</span></p>
<p id='status'>&nbsp;</p>
<script>
// Copyright 2020 Andrei Pangin
// Licensed under the Apache License, Version 2.0.
'use strict';
var root, rootLevel, px, pattern;
var reverse = false;
const levels = Array(39);
for (let h = 0; h < levels.length; h++) {
levels[h] = [];
}
const canvas = document.getElementById('canvas');
const c = canvas.getContext('2d');
const hl = document.getElementById('hl');
const status = document.getElementById('status');
const canvasWidth = canvas.offsetWidth;
const canvasHeight = canvas.offsetHeight;
canvas.style.width = canvasWidth + 'px';
canvas.width = canvasWidth * (devicePixelRatio || 1);
canvas.height = canvasHeight * (devicePixelRatio || 1);
if (devicePixelRatio) c.scale(devicePixelRatio, devicePixelRatio);
c.font = document.body.style.font;
const palette = [
[0xb2e1b2, 20, 20, 20],
[0x50e150, 30, 30, 30],
[0x50cccc, 30, 30, 30],
[0xe15a5a, 30, 40, 40],
[0xc8c83c, 30, 30, 10],
[0xe17d00, 30, 30, 0],
[0xcce880, 20, 20, 20],
];
function getColor(p) {
const v = Math.random();
return '#' + (p[0] + ((p[1] * v) << 16 | (p[2] * v) << 8 | (p[3] * v))).toString(16);
}
function f(level, left, width, type, title, inln, c1, int) {
levels[level].push({left: left, width: width, color: getColor(palette[type]), title: title,
details: (int ? ', int=' + int : '') + (c1 ? ', c1=' + c1 : '') + (inln ? ', inln=' + inln : '')
});
}
function samples(n) {
return n === 1 ? '1 sample' : n.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ',') + ' samples';
}
function pct(a, b) {
return a >= b ? '100' : (100 * a / b).toFixed(2);
}
function findFrame(frames, x) {
let left = 0;
let right = frames.length - 1;
while (left <= right) {
const mid = (left + right) >>> 1;
const f = frames[mid];
if (f.left > x) {
right = mid - 1;
} else if (f.left + f.width <= x) {
left = mid + 1;
} else {
return f;
}
}
if (frames[left] && (frames[left].left - x) * px < 0.5) return frames[left];
if (frames[right] && (x - (frames[right].left + frames[right].width)) * px < 0.5) return frames[right];
return null;
}
function search(r) {
if (r === true && (r = prompt('Enter regexp to search:', '')) === null) {
return;
}
pattern = r ? RegExp(r) : undefined;
const matched = render(root, rootLevel);
document.getElementById('matchval').textContent = pct(matched, root.width) + '%';
document.getElementById('match').style.display = r ? 'inherit' : 'none';
}
function render(newRoot, newLevel) {
if (root) {
c.fillStyle = '#ffffff';
c.fillRect(0, 0, canvasWidth, canvasHeight);
}
root = newRoot || levels[0][0];
rootLevel = newLevel || 0;
px = canvasWidth / root.width;
const x0 = root.left;
const x1 = x0 + root.width;
const marked = [];
function mark(f) {
return marked[f.left] >= f.width || (marked[f.left] = f.width);
}
function totalMarked() {
let total = 0;
let left = 0;
Object.keys(marked).sort(function(a, b) { return a - b; }).forEach(function(x) {
if (+x >= left) {
total += marked[x];
left = +x + marked[x];
}
});
return total;
}
function drawFrame(f, y, alpha) {
if (f.left < x1 && f.left + f.width > x0) {
c.fillStyle = pattern && f.title.match(pattern) && mark(f) ? '#ee00ee' : f.color;
c.fillRect((f.left - x0) * px, y, f.width * px, 15);
if (f.width * px >= 21) {
const chars = Math.floor(f.width * px / 7);
const title = f.title.length <= chars ? f.title : f.title.substring(0, chars - 2) + '..';
c.fillStyle = '#000000';
c.fillText(title, Math.max(f.left - x0, 0) * px + 3, y + 12, f.width * px - 6);
}
if (alpha) {
c.fillStyle = 'rgba(255, 255, 255, 0.5)';
c.fillRect((f.left - x0) * px, y, f.width * px, 15);
}
}
}
for (let h = 0; h < levels.length; h++) {
const y = reverse ? h * 16 : canvasHeight - (h + 1) * 16;
const frames = levels[h];
for (let i = 0; i < frames.length; i++) {
drawFrame(frames[i], y, h < rootLevel);
}
}
return totalMarked();
}
canvas.onmousemove = function() {
const h = Math.floor((reverse ? event.offsetY : (canvasHeight - event.offsetY)) / 16);
if (h >= 0 && h < levels.length) {
const f = findFrame(levels[h], event.offsetX / px + root.left);
if (f) {
if (f != root) getSelection().removeAllRanges();
hl.style.left = (Math.max(f.left - root.left, 0) * px + canvas.offsetLeft) + 'px';
hl.style.width = (Math.min(f.width, root.width) * px) + 'px';
hl.style.top = ((reverse ? h * 16 : canvasHeight - (h + 1) * 16) + canvas.offsetTop) + 'px';
hl.firstChild.textContent = f.title;
hl.style.display = 'block';
canvas.title = f.title + '\n(' + samples(f.width) + f.details + ', ' + pct(f.width, levels[0][0].width) + '%)';
canvas.style.cursor = 'pointer';
canvas.onclick = function() {
if (f != root) {
render(f, h);
canvas.onmousemove();
}
};
status.textContent = 'Function: ' + canvas.title;
return;
}
}
canvas.onmouseout();
}
canvas.onmouseout = function() {
hl.style.display = 'none';
status.textContent = '\xa0';
canvas.title = '';
canvas.style.cursor = '';
canvas.onclick = '';
}
canvas.ondblclick = function() {
getSelection().selectAllChildren(hl);
}
document.getElementById('reverse').onclick = function() {
reverse = !reverse;
render();
}
document.getElementById('search').onclick = function() {
search(true);
}
document.getElementById('reset').onclick = function() {
search(false);
}
window.onkeydown = function() {
if (event.ctrlKey && event.keyCode === 70) {
event.preventDefault();
search(true);
} else if (event.keyCode === 27) {
search(false);
}
}
f(0,0,289,3,'all')
f(1,0,5,3,'[unknown_Java]')
f(2,0,1,1,'kyo/bench/InterruptBench$$Lambda$57.0x0000000800d47a30.apply')
f(2,1,1,1,'kyo/core$$anon$5.apply')
f(2,2,3,6,'kyo/core$internal$KyoCont.effect',0,3,0)
f(1,5,284,1,'java/lang/Thread.run')
f(2,5,284,1,'java/util/concurrent/ThreadPoolExecutor$Worker.run')
f(3,5,284,1,'java/util/concurrent/ThreadPoolExecutor.runWorker')
f(4,5,5,1,'java/util/concurrent/FutureTask.run')
f(5,5,5,1,'java/util/concurrent/Executors$RunnableAdapter.call')
f(6,5,5,1,'java/util/concurrent/FutureTask.run')
f(7,5,5,1,'org/openjdk/jmh/runner/BenchmarkHandler$BenchmarkTask.call')
f(8,5,5,1,'org/openjdk/jmh/runner/BenchmarkHandler$BenchmarkTask.call')
f(9,5,5,1,'java/lang/reflect/Method.invoke')
f(10,5,5,1,'jdk/internal/reflect/DelegatingMethodAccessorImpl.invoke')
f(11,5,5,1,'jdk/internal/reflect/NativeMethodAccessorImpl.invoke')
f(12,5,5,1,'jdk/internal/reflect/NativeMethodAccessorImpl.invoke0')
f(13,5,5,1,'kyo/bench/jmh_generated/InterruptBench_forkKyo_jmhTest.forkKyo_Throughput')
f(14,5,5,1,'kyo/bench/jmh_generated/InterruptBench_forkKyo_jmhTest.forkKyo_thrpt_jmhStub')
f(15,5,5,1,'kyo/bench/Bench.forkKyo')
f(16,5,5,1,'kyo/bench/Bench.runLoop$2')
f(17,5,3,1,'kyo/concurrent/fibers$Fiber$$anon$10.apply')
f(18,5,3,1,'kyo/concurrent/fibers$Fiber$$anon$10.apply')
f(19,5,3,1,'kyo/concurrent/scheduler/IOPromise.block')
f(20,5,3,1,'kyo/concurrent/scheduler/IOPromise.loop$4')
f(21,5,3,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.acquireSharedInterruptibly')
f(22,5,3,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.acquire')
f(23,6,2,1,'java/util/concurrent/locks/LockSupport.park')
f(24,6,2,1,'jdk/internal/misc/Unsafe.park')
f(25,6,2,3,'[unknown]')
f(26,6,2,3,'/usr/lib/x86_64-linux-gnu/libc.so.6')
f(27,7,1,5,'entry_SYSCALL_64_after_hwframe')
f(28,7,1,5,'do_syscall_64')
f(29,7,1,5,'__x64_sys_futex')
f(30,7,1,5,'do_futex')
f(31,7,1,5,'futex_wait')
f(32,7,1,5,'futex_wait_queue_me')
f(33,7,1,5,'schedule')
f(34,7,1,5,'__schedule')
f(35,7,1,5,'finish_task_switch.isra.0')
f(17,8,2,1,'kyo/core$$anon$5.apply')
f(18,8,2,1,'kyo/core$$anon$5.apply')
f(19,8,2,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(20,8,2,1,'kyo/concurrent/fibers$Fibers$$Lambda$38.0x0000000800c3e600.apply')
f(21,8,2,1,'kyo/concurrent/fibers$Fibers.forkFiber$$anonfun$1')
f(22,8,2,1,'kyo/concurrent/scheduler/Scheduler$.schedule')
f(23,8,2,1,'kyo/concurrent/scheduler/Scheduler$.submit')
f(24,8,2,1,'kyo/concurrent/scheduler/Worker.enqueue')
f(25,8,2,1,'java/util/concurrent/locks/LockSupport.unpark')
f(26,8,2,1,'jdk/internal/misc/Unsafe.unpark')
f(27,8,2,3,'pthread_cond_signal')
f(28,8,2,5,'entry_SYSCALL_64_after_hwframe')
f(29,8,2,5,'do_syscall_64')
f(30,8,2,5,'__x64_sys_futex')
f(31,8,2,5,'do_futex')
f(32,8,2,5,'futex_wake')
f(33,8,2,5,'wake_up_q')
f(34,8,2,5,'_raw_spin_unlock_irqrestore')
f(4,10,1,1,'kyo/concurrent/scheduler/Coordinator$$$Lambda$49.0x0000000800d1d0e8.run')
f(5,10,1,1,'kyo/concurrent/scheduler/Coordinator$.$init$$$anonfun$1')
f(6,10,1,1,'kyo/concurrent/scheduler/Coordinator$.update')
f(7,10,1,1,'java/lang/Thread.sleep')
f(8,10,1,3,'[unknown]')
f(9,10,1,3,'/usr/lib/x86_64-linux-gnu/libc.so.6')
f(10,10,1,5,'entry_SYSCALL_64_after_hwframe')
f(11,10,1,5,'do_syscall_64')
f(12,10,1,5,'__x64_sys_futex')
f(13,10,1,5,'do_futex')
f(14,10,1,5,'futex_wait')
f(15,10,1,5,'futex_wait_queue_me')
f(16,10,1,5,'schedule')
f(17,10,1,5,'__schedule')
f(18,10,1,5,'finish_task_switch.isra.0')
f(4,11,278,1,'kyo/concurrent/scheduler/Scheduler$$$Lambda$52.0x0000000800d1ba80.run')
f(5,11,278,1,'kyo/concurrent/scheduler/Scheduler$.startWorkers$$anonfun$1')
f(6,11,278,1,'kyo/concurrent/scheduler/Worker.runWorker')
f(7,24,7,2,'kyo/concurrent/scheduler/IOTask.reenqueue',7,0,0)
f(8,24,6,2,'kyo/concurrent/scheduler/IOTask.curr',6,0,0)
f(8,30,1,2,'scala/runtime/BoxesRunTime.equals',1,0,0)
f(7,31,224,1,'kyo/concurrent/scheduler/IOTask.run')
f(8,32,2,2,'kyo/concurrent/scheduler/IOTask.curr',2,0,0)
f(8,34,220,1,'kyo/concurrent/scheduler/IOTask.eval')
f(9,42,59,1,'kyo/concurrent/scheduler/IOTask.finalize$1',12,0,0)
f(10,42,59,1,'kyo/concurrent/fibers$Fiber$$anon$11$$Lambda$60.0x0000000800d435d0.apply$mcV$sp',12,0,0)
f(11,42,59,1,'kyo/concurrent/fibers$.kyo$concurrent$fibers$Fiber$$anon$11$$_$apply$$anonfun$1',12,0,0)
f(12,42,59,1,'kyo/concurrent/fibers$.loop$9',12,0,0)
f(13,42,50,1,'kyo/concurrent/scheduler/IOPromise.kyo$concurrent$scheduler$IOPromise$$inline$complete',3,0,0)
f(14,42,50,1,'kyo/concurrent/scheduler/IOPromise.complete',3,0,0)
f(15,42,1,2,'java/util/concurrent/atomic/AtomicReference.compareAndSet',1,0,0)
f(16,42,1,2,'java/lang/invoke/VarHandleGuards.guard_LLL_Z',1,0,0)
f(17,42,1,2,'java/lang/invoke/VarHandleReferences$FieldInstanceReadWrite.compareAndSet',1,0,0)
f(15,43,48,1,'kyo/concurrent/scheduler/IOPromise$Pending.flush',2,0,0)
f(16,43,48,1,'kyo/concurrent/scheduler/IOPromise$Pending.loop$7',2,0,0)
f(17,44,47,1,'kyo/concurrent/scheduler/IOPromise$Pending$$anon$3.run',1,0,0)
f(18,45,46,1,'scala/runtime/function/JProcedure1.apply')
f(19,47,44,1,'scala/runtime/function/JProcedure1.apply')
f(20,47,6,2,'kyo/concurrent/scheduler/IOTask$$Lambda$62.0x0000000800d41a18.applyVoid',6,0,0)
f(21,47,6,2,'kyo/concurrent/scheduler/IOTask.loop$2$$anonfun$1',6,0,0)
f(22,48,5,2,'kyo/concurrent/scheduler/IOTask.loop$3',5,0,0)
f(20,53,38,2,'kyo/concurrent/scheduler/IOTask$$Lambda$66.0x0000000800d487a0.applyVoid',26,0,0)
f(21,53,38,2,'kyo/concurrent/scheduler/IOTask.loop$5$$anonfun$1',26,0,0)
f(22,53,1,2,'java/lang/invoke/Invokers$Holder.linkToTargetMethod',1,0,0)
f(23,53,1,2,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial',1,0,0)
f(24,53,1,2,'kyo/concurrent/scheduler/IOTask$$Lambda$67.0x0000000800d48ba8.<init>',1,0,0)
f(25,53,1,2,'java/lang/Object.<init>',1,0,0)
f(22,54,4,2,'kyo/concurrent/scheduler/Scheduler$.schedule',4,0,0)
f(23,54,4,2,'kyo/concurrent/scheduler/Worker.enqueueLocal',4,0,0)
f(24,55,3,2,'kyo/concurrent/scheduler/Queue.offer',3,0,0)
f(25,55,3,2,'kyo/concurrent/scheduler/Queue.tryModify',3,0,0)
f(26,55,3,2,'java/util/concurrent/atomic/AtomicBoolean.compareAndSet',3,0,0)
f(27,56,2,2,'java/lang/invoke/VarHandleGuards.guard_LII_Z',2,0,0)
f(28,57,1,2,'java/lang/invoke/VarHandle.checkExactAccessMode',1,0,0)
f(22,58,33,2,'kyo/package$KyoOps$.map$extension',21,0,0)
f(23,59,32,2,'kyo/package$KyoOps$.flatMap$extension',20,0,0)
f(24,59,32,2,'kyo/core$.transform',20,0,0)
f(25,60,31,2,'kyo/core$.kyo$core$$$_$transformLoop$1',19,0,0)
f(26,60,17,1,'kyo/concurrent/scheduler/IOTask$$Lambda$67.0x0000000800d48ba8.apply',5,0,0)
f(27,62,15,1,'kyo/concurrent/scheduler/IOTask.$anonfun$1',3,0,0)
f(28,62,15,1,'kyo/core$$anon$5.apply',3,0,0)
f(29,65,12,1,'kyo/core$.kyo$core$$$_$transformLoop$1')
f(30,65,12,1,'kyo/bench/InterruptBench$$Lambda$58.0x0000000800d42ae0.apply')
f(31,65,12,2,'kyo/bench/InterruptBench.iterate$2$$anonfun$adapted$1',12,0,0)
f(32,65,12,2,'kyo/bench/InterruptBench.iterate$2$$anonfun$3',12,0,0)
f(33,65,12,2,'kyo/bench/InterruptBench.iterate$2',12,0,0)
f(34,65,4,2,'java/lang/invoke/Invokers$Holder.linkToTargetMethod',4,0,0)
f(35,65,4,2,'java/lang/invoke/LambdaForm$DMH.0x0000000800d40400.newInvokeSpecial',4,0,0)
f(36,65,4,2,'java/lang/invoke/DirectMethodHandle.allocateInstance',4,0,0)
f(34,69,6,2,'kyo/concurrent/fibers$Fibers.forkFiber',6,0,0)
f(35,69,1,2,'java/lang/invoke/Invokers$Holder.linkToTargetMethod',1,0,0)
f(36,69,1,2,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial',1,0,0)
f(37,69,1,2,'java/lang/invoke/DirectMethodHandle.allocateInstance',1,0,0)
f(35,70,2,2,'kyo/locals$Locals$.save',2,0,0)
f(35,72,3,2,'kyo/package$KyoOps$.map$extension',3,0,0)
f(36,72,3,2,'kyo/package$KyoOps$.flatMap$extension',3,0,0)
f(37,72,3,2,'kyo/core$.transform',3,0,0)
f(38,72,3,2,'kyo/core$.kyo$core$$$_$transformLoop$1',3,0,0)
f(34,75,2,2,'kyo/package$KyoOps$.flatMap$extension',2,0,0)
f(35,75,2,2,'kyo/core$.transform',2,0,0)
f(36,75,2,2,'kyo/core$.kyo$core$$$_$transformLoop$1',2,0,0)
f(37,76,1,2,'kyo/core$$anon$5.<init>',1,0,0)
f(26,77,14,2,'kyo/core$$anon$5.<init>',14,0,0)
f(27,77,14,2,'kyo/core$internal$KyoCont.<init>',14,0,0)
f(28,88,3,2,'kyo/core$internal$Kyo.<init>',3,0,0)
f(15,91,1,1,'kyo/concurrent/scheduler/IOPromise.onComplete')
f(13,92,9,2,'scala/runtime/BoxesRunTime.boxToBoolean',9,0,0)
f(9,101,2,2,'kyo/concurrent/scheduler/IOTask.loop$2',2,0,0)
f(10,101,1,2,'java/lang/invoke/Invokers$Holder.linkToTargetMethod',1,0,0)
f(11,101,1,2,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial',1,0,0)
f(12,101,1,2,'java/lang/invoke/DirectMethodHandle.allocateInstance',1,0,0)
f(10,102,1,2,'kyo/concurrent/scheduler/IOPromise$Pending.add',1,0,0)
f(9,103,12,1,'kyo/concurrent/scheduler/IOTask.loop$5')
f(10,104,5,2,'java/lang/invoke/Invokers$Holder.linkToTargetMethod',5,0,0)
f(11,105,4,2,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial',4,0,0)
f(12,105,4,2,'kyo/concurrent/scheduler/IOTask$$Lambda$63.0x0000000800d40c00.<init>',4,0,0)
f(10,109,3,2,'java/util/concurrent/atomic/AtomicReference.compareAndSet',3,0,0)
f(11,109,3,2,'java/lang/invoke/VarHandleGuards.guard_LLL_Z',3,0,0)
f(12,109,3,2,'java/lang/invoke/VarHandleReferences$FieldInstanceReadWrite.compareAndSet',3,0,0)
f(10,112,2,2,'kyo/concurrent/scheduler/IOTask.<init>',2,0,0)
f(11,112,2,2,'kyo/concurrent/scheduler/IOPromise.<init>',2,0,0)
f(12,112,2,2,'kyo/concurrent/scheduler/IOPromise.<init>',2,0,0)
f(13,112,2,2,'java/util/concurrent/atomic/AtomicReference.<init>',2,0,0)
f(10,114,1,2,'kyo/concurrent/scheduler/Scheduler$.schedule',1,0,0)
f(11,114,1,2,'kyo/concurrent/scheduler/Worker.enqueueLocal',1,0,0)
f(12,114,1,2,'kyo/concurrent/scheduler/Queue.offer',1,0,0)
f(13,114,1,2,'java/lang/invoke/Invokers$Holder.linkToTargetMethod',1,0,0)
f(9,115,21,1,'kyo/concurrent/scheduler/IOTask.loop$8')
f(10,115,21,2,'kyo/concurrent/scheduler/IOPromise.kyo$concurrent$scheduler$IOPromise$$inline$complete',13,0,0)
f(11,115,21,2,'kyo/concurrent/scheduler/IOPromise.complete',13,0,0)
f(12,115,21,2,'kyo/concurrent/scheduler/IOPromise$Pending.flush',13,0,0)
f(13,115,21,2,'kyo/concurrent/scheduler/IOPromise$Pending.loop$7',13,0,0)
f(14,122,14,2,'kyo/concurrent/scheduler/IOPromise$Pending$$anon$3.run',6,0,0)
f(15,122,6,3,'itable stub')
f(15,128,3,1,'kyo/concurrent/scheduler/IOPromise$$anon$1.apply')
f(16,128,3,1,'kyo/concurrent/scheduler/IOPromise$$anon$1.apply')
f(17,128,3,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.releaseShared')
f(18,128,3,1,'java/util/concurrent/locks/AbstractQueuedSynchronizer.signalNext')
f(19,128,3,1,'java/util/concurrent/locks/LockSupport.unpark')
f(20,128,3,1,'jdk/internal/misc/Unsafe.unpark')
f(21,128,3,3,'pthread_cond_signal')
f(22,128,3,5,'entry_SYSCALL_64_after_hwframe')
f(23,128,3,5,'do_syscall_64')
f(24,128,3,5,'__x64_sys_futex')
f(25,128,3,5,'do_futex')
f(26,128,3,5,'futex_wake')
f(27,129,2,5,'wake_up_q')
f(28,129,2,5,'_raw_spin_unlock_irqrestore')
f(15,131,5,1,'scala/runtime/function/JProcedure1.apply')
f(16,132,4,1,'scala/runtime/function/JProcedure1.apply')
f(17,133,3,2,'kyo/concurrent/scheduler/IOTask$$Lambda$66.0x0000000800d487a0.applyVoid',3,0,0)
f(18,133,3,2,'kyo/concurrent/scheduler/IOTask.loop$5$$anonfun$1',3,0,0)
f(19,133,3,2,'kyo/concurrent/scheduler/Scheduler$.schedule',3,0,0)
f(20,133,3,2,'kyo/concurrent/scheduler/Worker.enqueueLocal',3,0,0)
f(21,135,1,2,'kyo/concurrent/scheduler/Queue.offer',1,0,0)
f(22,135,1,2,'java/lang/invoke/Invokers$Holder.linkToTargetMethod',1,0,0)
f(23,135,1,2,'java/lang/invoke/DirectMethodHandle$Holder.newInvokeSpecial',1,0,0)
f(24,135,1,2,'java/lang/invoke/DirectMethodHandle.allocateInstance',1,0,0)
f(9,136,113,1,'kyo/core$$anon$5.apply')
f(10,137,19,1,'kyo/concurrent/fibers$Fiber$$anon$11.apply')
f(11,137,19,2,'kyo/concurrent/fibers$Fiber$$anon$11.apply',19,0,0)
f(12,142,1,2,'kyo/concurrent/fibers$Fiber.interrupt',1,0,0)
f(12,143,6,2,'kyo/concurrent/scheduler/IOPromise.<init>',6,0,0)
f(13,143,6,2,'kyo/concurrent/scheduler/IOPromise.<init>',6,0,0)
f(14,143,6,2,'java/util/concurrent/atomic/AtomicReference.<init>',6,0,0)
f(12,149,5,2,'kyo/concurrent/scheduler/IOTask.ensure',5,0,0)
f(13,149,5,2,'kyo/concurrent/scheduler/IOTask.curr',5,0,0)
f(12,154,2,2,'kyo/package$KyoOps$.map$extension',2,0,0)
f(13,154,2,2,'kyo/package$KyoOps$.flatMap$extension',2,0,0)
f(14,154,2,2,'kyo/core$.transform',2,0,0)
f(15,154,2,2,'kyo/core$.kyo$core$$$_$transformLoop$1',2,0,0)
f(10,156,68,1,'kyo/core$$anon$5.apply')
f(11,161,12,1,'kyo/concurrent/fibers$Fiber$$anon$12.apply')
f(12,163,10,2,'kyo/concurrent/fibers$Fiber$$anon$12.apply',10,0,0)
f(13,163,1,2,'kyo/concurrent/fibers$Fiber$$anon$12.loop$10',1,0,0)
f(14,163,1,2,'kyo/concurrent/scheduler/IOPromise.kyo$concurrent$scheduler$IOPromise$$inline$complete',1,0,0)
f(15,163,1,2,'kyo/concurrent/scheduler/IOPromise.complete',1,0,0)
f(16,163,1,2,'java/util/concurrent/atomic/AtomicReference.compareAndSet',1,0,0)
f(17,163,1,2,'java/lang/invoke/VarHandleGuards.guard_LLL_Z',1,0,0)
f(18,163,1,2,'java/lang/invoke/VarHandleReferences$FieldInstanceReadWrite.compareAndSet',1,0,0)
f(13,164,9,2,'scala/runtime/BoxesRunTime.boxToBoolean',9,0,0)
f(11,173,32,1,'kyo/core$$anon$5.apply')
f(12,174,30,1,'kyo/core$.kyo$core$$$_$transformLoop$1',6,0,0)
f(13,176,4,3,'itable stub')
f(13,180,24,1,'kyo/concurrent/fibers$Fibers$$Lambda$38.0x0000000800c3e600.apply')
f(14,182,22,2,'kyo/concurrent/fibers$Fibers.forkFiber$$anonfun$1',21,0,0)
f(15,190,1,4,'OptoRuntime::new_instance_C(Klass*, JavaThread*)')
f(16,190,1,4,'InstanceKlass::allocate_instance(JavaThread*)')
f(17,190,1,4,'MemAllocator::allocate() const')
f(18,190,1,4,'MemAllocator::allocate_inside_tlab_slow(MemAllocator::Allocation&) const')
f(19,190,1,4,'CollectedHeap::tlab_alloc_reserve() const')
f(15,191,6,2,'kyo/concurrent/fibers$Fibers$$anon$29.<init>',6,0,0)
f(15,197,7,2,'kyo/concurrent/scheduler/IOTask.<init>',7,0,0)
f(16,202,2,2,'kyo/concurrent/scheduler/IOPromise.<init>',2,0,0)
f(17,202,2,2,'kyo/concurrent/scheduler/IOPromise.<init>',2,0,0)
f(12,204,1,1,'kyo/locals$Locals$$anon$2.apply')
f(11,205,19,2,'kyo/core$.kyo$core$$$_$transformLoop$1',15,0,0)
f(12,211,9,3,'itable stub')
f(12,220,4,1,'kyo/concurrent/fibers$Fiber$$anon$11$$Lambda$61.0x0000000800d43ae0.apply')
f(13,223,1,2,'kyo/concurrent/fibers$.kyo$concurrent$fibers$Fiber$$anon$11$$_$apply$$anonfun$adapted$1',1,0,0)
f(14,223,1,2,'kyo/concurrent/fibers$.apply$$anonfun$2',1,0,0)
f(10,224,24,2,'kyo/core$.kyo$core$$$_$transformLoop$1',12,0,0)
f(11,231,17,1,'kyo/core$$anon$5.<init>',5,0,0)
f(12,231,17,1,'kyo/core$internal$KyoCont.<init>',5,0,0)
f(13,232,4,6,'kyo/core$internal$KyoCont.effect',0,4,0)
f(13,236,3,6,'kyo/core$internal$KyoCont.value',0,3,0)
f(13,239,3,6,'kyo/core$internal$KyoRoot.value',0,3,0)
f(13,242,2,1,'kyo/ios$KyoIO.effect')
f(13,244,4,3,'vtable stub')
f(10,248,1,3,'vtable stub')
f(9,249,3,6,'kyo/core$internal$KyoCont.effect',0,3,0)
f(9,252,2,3,'vtable stub')
f(8,254,1,2,'scala/runtime/BoxesRunTime.equals',1,0,0)
f(7,255,30,1,'kyo/concurrent/scheduler/Queue.poll',2,0,0)
f(8,257,28,1,'kyo/concurrent/scheduler/Queue.modify')
f(9,257,17,2,'java/util/concurrent/atomic/AtomicBoolean.compareAndSet',17,0,0)
f(10,263,11,2,'java/lang/invoke/VarHandleGuards.guard_LII_Z',11,0,0)
f(11,269,5,2,'java/lang/invoke/VarHandleInts$FieldInstanceReadWrite.compareAndSet',5,0,0)
f(12,270,4,2,'java/util/Objects.requireNonNull',4,0,0)
f(9,274,11,2,'kyo/concurrent/scheduler/Queue$$Lambda$59.0x0000000800d43310.apply',11,0,0)
f(10,274,11,2,'kyo/concurrent/scheduler/Queue.addAndPoll$$anonfun$1',11,0,0)
f(11,274,11,2,'scala/collection/mutable/PriorityQueue.dequeue',11,0,0)
f(12,280,5,2,'scala/collection/mutable/PriorityQueue$ResizableArrayAccess.p_array',5,0,0)
f(7,285,2,1,'kyo/concurrent/scheduler/Scheduler$.idle')
f(8,285,2,1,'kyo/concurrent/scheduler/Worker.park')
f(9,285,2,1,'java/util/concurrent/locks/LockSupport.parkNanos')
f(10,285,2,1,'jdk/internal/misc/Unsafe.park')
f(11,285,2,3,'[unknown]')
f(12,285,2,3,'/usr/lib/x86_64-linux-gnu/libc.so.6')
f(13,285,2,5,'entry_SYSCALL_64_after_hwframe')
f(14,285,2,5,'do_syscall_64')
f(15,285,2,5,'__x64_sys_futex')
f(16,285,2,5,'do_futex')
f(17,285,2,5,'futex_wait')
f(18,285,2,5,'futex_wait_queue_me')
f(19,285,2,5,'schedule')
f(20,285,2,5,'__schedule')
f(21,285,2,5,'finish_task_switch.isra.0')
f(7,287,1,1,'kyo/concurrent/scheduler/Scheduler$.steal')
f(8,287,1,2,'kyo/concurrent/scheduler/Worker.load',1,0,0)
f(7,288,1,2,'kyo/concurrent/scheduler/Worker.stop$1',1,0,0)
search();
</script></body></html>
Raw
jmh-result-67f4e4a.json
[
{
"jmhVersion" : "1.36",
"benchmark" : "kyo.bench.InterruptBench.forkKyo",
"mode" : "thrpt",
"threads" : 1,
"forks" : 1,
"jvm" : "/home/runner/.jabba/jdk/openjdk@1.17.0/bin/java",
"jvmArgs" : [
"-Dcats.effect.tracing.mode=DISABLED"
],
"jdkVersion" : "17",
"vmName" : "OpenJDK 64-Bit Server VM",
"vmVersion" : "17+35-2724",
"warmupIterations" : 5,
"warmupTime" : "1 s",
"warmupBatchSize" : 1,
"measurementIterations" : 3,
"measurementTime" : "1 s",
"measurementBatchSize" : 1,
"primaryMetric" : {
"score" : 3901.3844924358673,
"scoreError" : 1160.6772453431552,
"scoreConfidence" : [
2740.7072470927124,
5062.061737779022
],
"scorePercentiles" : {
"0.0" : 3844.401480511105,
"50.0" : 3889.722696750564,
"90.0" : 3970.0293000459337,
"95.0" : 3970.0293000459337,
"99.0" : 3970.0293000459337,
"99.9" : 3970.0293000459337,
"99.99" : 3970.0293000459337,
"99.999" : 3970.0293000459337,
"99.9999" : 3970.0293000459337,
"100.0" : 3970.0293000459337
},
"scoreUnit" : "ops/s",
"rawData" : [
[
3844.401480511105,
3889.722696750564,
3970.0293000459337
]
]
},
"secondaryMetrics" : {
}
}
]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment