Получать ввод с микрофона от 2-х процессов одновременно

Вот правдоподобный подход для рассмотрения.

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

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

РЕДАКТИРОВАТЬ: добавлено для уточнения

Этот пример кода утилиты звукозаписи Java открывается a TargetDataLine к микрофону и сохраняет данные с него в массив (строки 69, 70). Вместо того, чтобы хранить данные в массиве, я предлагаю вам создать два объекта SourceDataLine и записать данные в каждый из них.

recordBytes = new ByteArrayOutputStream();
secondStreamBytes = new ByteArrayOutputStream();

isRunning = true;

while (isRunning) {
    bytesRead = audioLine.read(buffer, 0, buffer.length);
    recordBytes.write(buffer, 0, bytesRead);
    secondStreamBytes.write(buffer, 0, bytesRead);
}

Надеюсь, не будет слишком сложно понять, как настроить ваши две программы для чтения с созданных строк, а не с линии микрофона. Я не могу дать руководство о том, как это сделать.

РЕДАКТИРОВАТЬ 2: Я бы хотел, чтобы некоторые другие люди присоединились. Я немного не в себе, чтобы делать что-то необычное с потоками. И код, который вы даете, настолько минимален, что я до сих пор не понимаю, что происходит или как все связано.

FWTW: (1) Являются ли данные, которые вы добавляете в «серию 1», потоковыми данными? Если да, можете ли вы добавить строку в этот цикл for и записать те же данные в поток, потребляемый другим классом? (Это был бы способ использования данных микрофона «последовательно», а не «параллельно».)

(2) Потоки данных часто включают код, который блокируется или выполняется с разной скоростью из-за непредсказуемого способа переключения процессора между задачами. Таким образом, если вы напишете «разветвитель» (как я пытался проиллюстрировать, изменив код чтения микрофона, который я связал ранее), может возникнуть ситуация, когда код будет работать только настолько быстро, насколько медленнее из двух «разветвителей» в данный момент времени. момент. Возможно, вам придется включить некоторую буферизацию и использовать отдельные потоки для двух получателей данных микрофона.

Недавно я написал свой первый код буферизации для ситуации, когда линия чтения с микрофона отправляет поток в функцию микширования звука в другом потоке. Я написал это всего несколько недель назад, и это первый раз, когда я столкнулся с попыткой запустить поток через потоки с барьером потока, поэтому я не знаю, является ли идея, к которой я пришел, лучшим способом сделать такого рода вещи . Но ему удается стабильно подавать сигнал от микрофона к микшеру, без пропаданий и потерь.

Считыватель микрофона считывает буфер данных, затем добавляет этот byte[] буфер в ConcurrentLinkedQueue<Byte[]>.

Из другого потока код микширования аудио опрашивает ConcurrentLinkedQueue для данных.

Я немного поэкспериментировал и в настоящее время размер буфера byte[] составляет 512 байт, а ConcurrentLinkedQueue настроен на хранение до 12 «буферов», прежде чем он начнет выбрасывать самые старые буферы (структура FIFO). Кажется, этих небольших буферов достаточно, чтобы приспособиться, когда код обработки микрофона временно опережает микшер.

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

Может быть, кто-то еще взвесит свое мнение, или, может быть, стоит поэкспериментировать с этим предложением и опробовать его.

Во всяком случае, это лучшее, что я могу сделать, учитывая мой ограниченный опыт в этом. Я надеюсь, что вы сможете что-то придумать.