таймер Java не работает при использовании ЮНА вызов Win32 WaitForSingleObject()

Question

Я пытаюсь прекратить ЮНА вызов WaitForSignleObject() с Timer, который прерывает текущий поток:

final Thread thread = Thread.currentThread(); 
Timer timer = new Timer(); 
timer.schedule(new TimerTask() { 
    public void run() { 
    thread.interrupt(); 
    } 
}, 3000); 

try {    
    Kernel32.INSTANCE.WaitForSingleObject(processInfo.hProcess, Kernel32.INFINITE); 
    ... 
} catch (InterruptedException e) { 
} 

Проблема заключается в том, что TimerTask.run() является не вызывается через 3 секунды, как и ожидалось, вызывается только после того, как WaitForSingleObject() выходит из себя. Что я делаю не так?

Спасибо!

Answer 1

Механизм прерывания потока - это специфичная для Java функция, поэтому неудивительно, что собственный код не уважает его.

Если вам нужен только тайм-аут, вы можете использовать второй аргумент WaitForSingleObject(). Если вам нужна более сложная логика, вы можете create an event уведомить ожидающий поток о прерывании и использовать WaitForMultipleObjects() на этом мероприятии и ваш hProcess.

Answer 2

При взгляде на документацию Microsoft для WaitForSingleObject есть предположение, что вы можете подумать о WaitForSingleObjectEx вместо этого (чтобы ввести «аварийное состояние ожидания»).

Answer 3

Проблема заключается в том, что TimerTask.run() не вызывается после 3 секунд прошло, как и ожидалось, это называется только после WaitForSingleObject() выходит сам. Что я делаю не так?

Простой ответ: вы делаете блокирующий вызов в операционной системе. Пока ваш поток заблокирован, TimerTask в этом потоке не будет срабатывать.

Даже если вы запустили TimerTask в другом потоке, маловероятно, что прерывание будет работать, так как Thread.interrupt является специфичной для Java функцией (как указывал @axtavt).

Если вам нужна дополнительная помощь, пожалуйста, создайте другое сообщение и объясните, зачем вам это нужно и каковы ваши ограничения (что-то более конкретное, чем «... он ломает мой API»). Возможно, мы найдем альтернативный подход.

Answer 4

Довольно много ошибок в этом простом коде;

• В течение run() код прерывает текущий поток вызовов - бесполезно, вы хотите, чтобы поток выполнял собственный вызов.
• Вам необходимо обработать прерывание собственного вызова.

Ниже ссылка на способ правильной обработки со стороны java. Detecting thread interruption with JNA native wait call (Windows)

Со стороны WinAPI: в зависимости от вашего случая вам может потребоваться CloseHandle, SetEvent или любое другое уведомление, которое вам нужно. Затем, вернувшись из WaitForSingleObject, проверьте состояние объекта и перетащите InterruptedException, если вам нужно.