You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jianbin Chen (Jira)" <ji...@apache.org> on 2024/08/02 03:37:00 UTC
[jira] [Created] (KAFKA-17244) java.base/java.lang.VirtualThread$VThreadContinuation.onPinned
Jianbin Chen created KAFKA-17244:
------------------------------------
Summary: java.base/java.lang.VirtualThread$VThreadContinuation.onPinned
Key: KAFKA-17244
URL: https://issues.apache.org/jira/browse/KAFKA-17244
Project: Kafka
Issue Type: Wish
Affects Versions: 3.7.1
Reporter: Jianbin Chen
{code:java}
Thread[#121,ForkJoinPool-1-worker-2,5,CarrierThreads]
java.base/java.lang.VirtualThread$VThreadContinuation.onPinned(VirtualThread.java:183)
java.base/jdk.internal.vm.Continuation.onPinned0(Continuation.java:393)
java.base/java.lang.VirtualThread.tryYield(VirtualThread.java:756)
java.base/java.lang.Thread.yield(Thread.java:443)
java.base/java.util.concurrent.ConcurrentHashMap.initTable(ConcurrentHashMap.java:2295)
java.base/java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1017)
java.base/java.util.concurrent.ConcurrentHashMap.putIfAbsent(ConcurrentHashMap.java:1541)
org.apache.kafka.common.record.CompressionRatioEstimator.getAndCreateEstimationIfAbsent(CompressionRatioEstimator.java:96)
org.apache.kafka.common.record.CompressionRatioEstimator.estimation(CompressionRatioEstimator.java:59)
org.apache.kafka.clients.producer.internals.ProducerBatch.<init>(ProducerBatch.java:95)
org.apache.kafka.clients.producer.internals.ProducerBatch.<init>(ProducerBatch.java:83)
org.apache.kafka.clients.producer.internals.RecordAccumulator.appendNewBatch(RecordAccumulator.java:399)
org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:350) <== monitors:1
org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:1025)
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:947) {code}
Because there is synchronized in the {{RecordAccumulator.append}} method, which causes the virtual thread to be {{{}onPinned{}}}, if this is considered an optimization item, please assign it to me, and I will try to optimize the problem.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)