タイムアウトは1秒程度を想定しています。
ネットワーク処理において1秒は短すぎて切れまくってしまいます。逆にUI処理において1秒の停止は遅過ぎで利用者はストレスが溜まることでしょう。結局、UIスレッドでネットワーク処理・オーディオ処理を行うこと自体が非現実的です。ですので質問者さんの希望を満たすようなライブラリは(kunifさんも回答されているように)無いのかもしれません。
一般論としては、ネットワーク処理においてはノンブロッキングI/Oを使います。ノンブロッキングI/Oであれば、バッファから受信済みのデータのみを扱うため処理がブロックされることはありません。オーディオ再生に追いつく程度のネットワーク速度があれば途切れることなく再生できることでしょう。これはあくまでネットワークダウンロード部分に限定した話であり、ダウンロード後、音声ファイルのデコード等の処理を考慮すればやはりUIスレッドで処理することは非現実的という結論が変わることはありません。
あくまでUIスレッドでの処理にこだわる質問者さんには関係ありませんが、参考情報として。
実はWindows Vista以降にはMedia Foundationといって、メディアプレーヤーを構成する各種機能がAPIとして提供されています。具体的には
- 各種ネットワーク処理(HTTPやRTSP、それらのバッファリングやネットワーク再接続など)
- 各種コーデックによるデコード
- VideoやAudioの出力、もしくは各種コーデックでの再エンコード
- これらをスムーズに処理するためのスレッドプール
などの機能を備えています。C/C++言語向けのAPIしか用意されていませんが、Interopを頑張って書けばC#言語からも呼び出せます。自由度が高い分、APIがそこそこ複雑なためInteropコードを書くのには挫けるため、C++言語での呼び出しサンプルを載せておきます。
#include <chrono>
#include <string>
#include <thread>
#include <assert.h>
#include <wrl/client.h>
#include <mfapi.h>
#include <mfidl.h>
void check(HRESULT hr) { if (FAILED(hr)) throw hr; }
#include "get.h" // https://github.com/sayurin/get
#pragma comment(lib, "mf.lib")
#pragma comment(lib, "mfplat.lib")
using namespace std::literals;
struct MF {
MF() { check(MFStartup(MF_VERSION, MFSTARTUP_FULL)); }
~MF() { check(MFShutdown()); }
};
auto CreateSession(std::wstring const& url) {
auto mediaSession = sayuri::get(MFCreateMediaSession, nullptr);
auto topology = sayuri::get(MFCreateTopology);
// create source node.
auto sourceNode = sayuri::get(MFCreateTopologyNode, MF_TOPOLOGY_SOURCESTREAM_NODE);
auto sourceResolver = sayuri::get(MFCreateSourceResolver);
MF_OBJECT_TYPE objectType;
auto object = GET(sourceResolver, CreateObjectFromURL, url.c_str(), MF_RESOLUTION_MEDIASOURCE, nullptr, &objectType);
assert(objectType == MF_OBJECT_MEDIASOURCE);
Microsoft::WRL::ComPtr<IMFMediaSource> mediaSource;
check(object.As(&mediaSource));
auto presentationDescriptor = GET(mediaSource, CreatePresentationDescriptor);
auto count = GET(presentationDescriptor, GetStreamDescriptorCount);
assert(count == 1);
BOOL selected;
auto streamDescriptor = GET(presentationDescriptor, GetStreamDescriptorByIndex, 0, &selected);
check(sourceNode->SetUnknown(MF_TOPONODE_SOURCE, mediaSource.Get()));
check(sourceNode->SetUnknown(MF_TOPONODE_PRESENTATION_DESCRIPTOR, presentationDescriptor.Get()));
check(sourceNode->SetUnknown(MF_TOPONODE_STREAM_DESCRIPTOR, streamDescriptor.Get()));
check(topology->AddNode(sourceNode.Get()));
// create output node.
auto activate = sayuri::get(MFCreateAudioRendererActivate);
auto outputNode = sayuri::get(MFCreateTopologyNode, MF_TOPOLOGY_OUTPUT_NODE);
check(outputNode->SetObject(activate.Get()));
check(outputNode->SetUINT32(MF_TOPONODE_NOSHUTDOWN_ON_REMOVE, TRUE));
check(topology->AddNode(outputNode.Get()));
check(sourceNode->ConnectOutput(0, outputNode.Get(), 0));
check(mediaSession->SetTopology(0, topology.Get()));
return std::move(mediaSession);
}
int wmain() {
MF mf;
auto session = CreateSession(L"http://www.example.co.jp/sample.mp3"s);
auto startPosition = sayuri::get(PropVariantInit);
check(session->Start(&GUID_NULL, &startPosition));
PropVariantClear(&startPosition);
// すべての処理は別スレッドで動作しているため、呼び出しスレッドは停止可能
std::this_thread::sleep_for(20s);
check(session->Stop());
}