Дамп потока показывает состояние потока всегда TIMED_WAITING - PullRequest
Новая
       18

Дамп потока показывает состояние потока всегда TIMED_WAITING

0 голосов
/ 07 июля 2019

Я создал программу, в которой он использует платформу Executor.Я создал один поток, который запланирован периодически.

Вот полный исходный код того же: 

package com.example;
import java.security.SecureRandom;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ExecutorFrameworkDemo {

    private static final Logger LOGGER = LoggerFactory.getLogger(ExecutorFrameworkDemo.class);

    static {
        long refresh = 120000;
        long initialDelay = 120000;
        ScheduledExecutorService scheduledThreadPool = null;
        SecureRandom sr = new SecureRandom();
        scheduledThreadPool = Executors.newSingleThreadScheduledExecutor((Runnable run) -> {
        Thread t = Executors.defaultThreadFactory().newThread(run);
        t.setDaemon(true);
        t.setName("Demo-pool");
        t.setUncaughtExceptionHandler(
                (thread, e) -> LOGGER.error("Uncaught exception for Demo-pool thread " + thread.getName(), e));
        return t;
    });

    scheduledThreadPool.scheduleAtFixedRate(() -> {
        System.out.println("Executing thread " + Thread.currentThread().toString() + "at" + new Date());

    }, initialDelay + sr.nextInt((int) refresh / 4), refresh + sr.nextInt((int) refresh / 4),
            TimeUnit.MILLISECONDS);
    }
    public static void main(String[] args) throws InterruptedException {
        System.out.println("Inside main thread");
        Thread.sleep(50000000);
        System.out.println("Inside main thread, after main's Sleep delay");
    }
}

Он создает один поток, который запускается вфиксированный график;на самом деле я вижу результат через каждые 2 минуты + несколько секунд.

В то же время я непрерывно выполнял дамп потока, надеясь, что в какой-то момент времени состояние потока будет RUNNABLE однако он всегда дает мне TIMED_WAITED.

Ниже приведен фактический дамп потока для того же самого: 


"Demo-pool" #12 daemon prio=5 os_prio=31 tid=0x00007f96f3230000 nid=0x5603 waiting on condition [0x0000700007752000]
   java.lang.Thread.State: TIMED_WAITING (parking)
        at sun.misc.Unsafe.park(Native Method)
        - parking to wait for  <0x00000007976182f0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
        at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
        at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
        at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
        at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)

Это случайность, я нев состоянии видеть состояние RUNNABLE?

Я беру дампы потоков, используя jstack, используя shell-скрипт, в бесконечном цикле, как показано ниже:

Скрипт для принятия Thread-dump: 

#!/bin/bash
itr=0
while true
  do
     (( ++itr ))
      jstack $1 > jstack_Iteration_${itr}
  done

где $ 1 - PID процесса java, переданный в качестве аргумента команды.

1 Ответ

1 голос
/ 07 июля 2019

Видеть поток в RUNNABLE означает, что вы делаете дамп в точную микросекунду, где он делает System.out.println.Это невероятно, черт возьми.Выполните более длительную реализацию вашей Runnable, например, ожидание занятости в виде цикла: 

for (int i = 0; i < 10000000; i++) {
    // do nothing
}

Не выполняйте Thread.sleep или wait, иначе вы окажетесь вдругое состояние, чем RUNNABLE.

...