Здравствуйте,
Пишу многопоточное приложение на Java для конвертации видео и загрузки на ютьюб. Столкнулся со странной особенностью - она даже в плюс, то есть никак мне не мешает, но я понимаю, что это следствие ошибки и кривого проектирования, и хочу понять, где сделал глупость.
В приложении есть несколько потоков:
- поток, запускающий процесс кодировщика FFMpeg, забирающий данные из его вывода (консольного буфера) - класс наследуется от Thread;
- поток, запускающий этот поток, и привязывающийся к нему через waitFor() - ServiceRunner, класс наследуется от Thread;
- главный поток - в цикле по некоторому таймеру проверяет, не выставлен ли флаг остановки (если выставлен - прибивает системный процесс ffmpeg, поскольку иного способа его завершить нету, и проводит финализацию, вызывая нужную логику других классов;
- поток, обрабатывающий SwingUI, отрисовка интерфейса;
- в режиме "только загрузка без конвертации" есть ещё один поток, обновляющий Elapsed time и Remaining time счётчики раз в секунду по таймеру;
- поток Browser (extends Thread) - загрузка данных на ютьюб и обращения к API, использует Apache HttpClient
Всё работает довольно предсказуемо (кроме мелких нюансов вроде того, что в момент остановки из-за кривого кода могут быть не согласованы состояния в разных классах), кроме одного странного момента.
А именно, при запуске происходит блокирование всех потоков (ServiceRunner и Main) до того момента, как запущенный поток HttpConnect (static inner класс внутри Browser) получит данные. Этот HttpConnect - типа встроенного простейшего веб-сервера. Его задача - принять от ютьюба токен доступа, переданный по ссылке в редиректе. И вывести ссылку на панель управления видеороликами, чтобы юзер смог использовать открытую вкладку с пользой.
И вот здесь странно: стартует новый поток, в конструктор класса передаётся сокет, возвращаемый через accept(), аналогичный код работал в массе других проектов. Но здесь он работает не так. А именно, пока этот сокет не получит данные, кодирование не стартует. StreamGobbler, получающий данные от ffmpeg, и в этом режиме ещё и запускающий Browser (поскольку из Main этого сделать никак не получалось, весь код после старта этого потока не исполнялся) - не выполняется. Как показал отладочный вывод, цикл с таймерами в Main не выполняется тоже. Не выполняется ничего, кроме потока, где исполняется код класса Browser. UI, правда, работает.
И из-за этого мы не можем начать кодирование, пока пользователь не даст приложению доступ на ютьюб. В комбинированном режиме это может даже и логично, но ведь мы теряем драгоценное время. А могли бы выполнять полезную работу.
Как мне переписать код, чтобы проблемы не было?