ssheldon / rust-dispatch Goto Github PK

extern crate dispatch;

use std::thread;
use std::process::exit;
use dispatch::{Queue, QueuePriority};
use objc::{{sel, sel_impl, msg_send, class}, runtime::{BOOL, YES, NO}};

pub fn is_main_thread() -> bool {
    unsafe {
        let thread = class!(NSThread);
        let b : BOOL = msg_send![thread, isMainThread];
        match b {
            YES => true,
            NO => false
        }
    }
}

fn test_on_main(queue: Queue) {

    queue.clone().exec_async(move || {
        let main = Queue::main();
        main.exec_async(|| {
            println!("Running from {:?} isMainThread? {}", thread::current().name(), is_main_thread());
            exit(0);
        });
    });
}

fn main() {
    // Read from stdin on a background queue so that the main queue is free
    // to handle other events. All printing still occurs through the main
    // queue to avoid jumbled output.
    cacao::utils::activate_cocoa_multithreading();
    println!("Initial Thread {:?} isMainThread? {}", thread::current().name(), is_main_thread());
    test_on_main(Queue::global(QueuePriority::Default));

    unsafe {
        dispatch::ffi::dispatch_main();
    }
}

error[E0080]: this static likely exhibits undefined behavior
   --> /Users/mehcode/.cargo/registry/src/github.com-1ecc6299db9ec823/dispatch-0.1.3/src/ffi.rs:138:1
    |
138 | pub static DISPATCH_QUEUE_CONCURRENT: &'static dispatch_object_s = unsafe { &_dispatch_queue_attr_concurrent };
    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ type validation failed: encountered a value of an uninhabited type at .<deref>
    |
    = note: The rules on what exactly is undefined behavior aren't clear, so this check might be overzealous. Please open an issue on the rust compiler repository if you believe it should not be considered undefined behavior

❯ rustc --version
rustc 1.31.0-nightly (424a749a0 2018-10-21)