[WTF] Drop Thread::create(obsolete things) API since we can use lambda
[WebKit-https.git] / Source / WebCore / Modules / webaudio / AsyncAudioDecoder.h
1 /*
2  * Copyright (C) 2011, Google Inc. All rights reserved.
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
7  * 1.  Redistributions of source code must retain the above copyright
8  *    notice, this list of conditions and the following disclaimer.
9  * 2.  Redistributions in binary form must reproduce the above copyright
10  *    notice, this list of conditions and the following disclaimer in the
11  *    documentation and/or other materials provided with the distribution.
12  *
13  * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' AND ANY
14  * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
15  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
16  * DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY
17  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
18  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
19  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
20  * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
21  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
22  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
23  */
24
25 #pragma once
26
27 #include <memory>
28 #include <wtf/Forward.h>
29 #include <wtf/MessageQueue.h>
30 #include <wtf/RefPtr.h>
31 #include <wtf/Threading.h>
32
33 namespace JSC {
34 class ArrayBuffer;
35 }
36
37 namespace WebCore {
38
39 class AudioBuffer;
40 class AudioBufferCallback;
41
42 // AsyncAudioDecoder asynchronously decodes audio file data from an ArrayBuffer in a worker thread.
43 // Upon successful decoding, a completion callback will be invoked with the decoded PCM data in an AudioBuffer.
44
45 class AsyncAudioDecoder {
46     WTF_MAKE_NONCOPYABLE(AsyncAudioDecoder);
47 public:
48     AsyncAudioDecoder();
49     ~AsyncAudioDecoder();
50
51     // Must be called on the main thread.
52     void decodeAsync(Ref<JSC::ArrayBuffer>&& audioData, float sampleRate, RefPtr<AudioBufferCallback>&& successCallback, RefPtr<AudioBufferCallback>&& errorCallback);
53
54 private:
55     class DecodingTask {
56         WTF_MAKE_NONCOPYABLE(DecodingTask);
57     public:
58         DecodingTask(Ref<JSC::ArrayBuffer>&& audioData, float sampleRate, RefPtr<AudioBufferCallback>&& successCallback, RefPtr<AudioBufferCallback>&& errorCallback);
59         void decode();
60         
61     private:
62         JSC::ArrayBuffer& audioData() { return m_audioData; }
63         float sampleRate() const { return m_sampleRate; }
64         AudioBufferCallback* successCallback() { return m_successCallback.get(); }
65         AudioBufferCallback* errorCallback() { return m_errorCallback.get(); }
66         AudioBuffer* audioBuffer() { return m_audioBuffer.get(); }
67
68         void notifyComplete();
69
70         Ref<JSC::ArrayBuffer> m_audioData;
71         float m_sampleRate;
72         RefPtr<AudioBufferCallback> m_successCallback;
73         RefPtr<AudioBufferCallback> m_errorCallback;
74         RefPtr<AudioBuffer> m_audioBuffer;
75     };
76     
77     void runLoop();
78
79     RefPtr<Thread> m_thread;
80     Lock m_threadCreationMutex;
81     MessageQueue<DecodingTask> m_queue;
82 };
83
84 } // namespace WebCore