zhangyiss/mlx
1
0
Fork 0
mirror of https://github.com/ml-explore/mlx.git synced 2025-07-16 13:51:13 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix order device -> scheduler (#1039)

Browse Source
This commit is contained in:
Awni Hannun 2024-04-26 13:46:41 -07:00 committed by GitHub
parent 5bfe89bdb1
commit 67d1894759
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
mlx/scheduler.h
View File

@ -24,7 +24,9 @@ struct StreamThread {
std::thread thread; std::thread thread;
StreamThread(Stream stream) StreamThread(Stream stream)
: stop(false), stream(stream), thread(&StreamThread::thread_fn, this) {} : stop(false), stream(stream), thread(&StreamThread::thread_fn, this) {
metal::new_stream(stream);
}
~StreamThread() { ~StreamThread() {
synchronize(stream); synchronize(stream);
@ -37,7 +39,6 @@ struct StreamThread {
} }
void thread_fn() { void thread_fn() {
bool initialized = false;
while (true) { while (true) {
std::function<void()> task; std::function<void()> task;
{ {
@ -50,15 +51,6 @@ struct StreamThread {
q.pop(); q.pop();
} }
// thread_fn may be called from a static initializer and we cannot
// call metal-cpp until all static initializers have completed. waiting
// for a task to arrive means that user code is running so metal-cpp
// can safely be called.
if (!initialized) {
initialized = true;
metal::new_stream(stream);
}
task(); task();
} }
} }