Add immediate queue binding

Author: szymon-zadworny

oneapi-rs-sys/include/queue.hpp

@@ -15,6 +15,7 @@
 
 namespace sycl_shims::queue {
 std::unique_ptr<Queue> new_queue();
+std::unique_ptr<Queue> new_queue_immediate();
 std::unique_ptr<Queue> new_queue_from_device(Device const &);
 std::unique_ptr<Queue> clone(Queue const &);
 std::unique_ptr<Event> memset(std::unique_ptr<Queue> &, std::uint8_t * ptr, int value, std::size_t num_bytes);

oneapi-rs-sys/src/queue-sys.rs

@@ -19,6 +19,7 @@ pub mod ffi {
         type Event = crate::types::ffi::Event;
 
         fn new_queue() -> UniquePtr<Queue>;
+        fn new_queue_immediate() -> UniquePtr<Queue>;
         fn new_queue_from_device(device: &Device) -> UniquePtr<Queue>;
         fn clone(queue: &Queue) -> UniquePtr<Queue>;
         unsafe fn memset(queue: &mut UniquePtr<Queue>, ptr: *mut u8, value: i32, num_bytes: usize) -> UniquePtr<Event>;

oneapi-rs-sys/src/queue.cpp

@@ -10,10 +10,19 @@
 #include "oneapi-rs-sys/src/queue-sys.rs.h"
 
 using sycl::property::queue::in_order;
+using sycl::ext::intel::property::queue::immediate_command_list;
 
 namespace sycl_shims::queue {
 std::unique_ptr<Queue> new_queue() {
-  return std::make_unique<Queue>(sycl::queue({in_order()}));
+  return std::make_unique<Queue>(sycl::queue({
+    in_order()
+  }));
+}
+std::unique_ptr<Queue> new_queue_immediate() {
+  return std::make_unique<Queue>(sycl::queue({
+    in_order(),
+    immediate_command_list()
+  }));
 }
 std::unique_ptr<Queue> new_queue_from_device(Device const & device) {
   return std::make_unique<Queue>(sycl::queue(device, {in_order()}));

oneapi-rs/src/queue.rs

@@ -22,6 +22,11 @@ impl Queue {
         Self(ffi::new_queue())
     }
 
+    /// Construct an immediate `Queue` based on the device returned from the default selector.
+    pub fn new_immediate() -> Self {
+        Self(ffi::new_queue_immediate())
+    }
+
     /// Allocates zeroed memory and creates a host-side [`Buffer`] that can store an array of T.
     pub fn alloc_host<T: Pod>(&mut self, len: usize) -> BufferInProgress<T, UsmAllocator<HostAllocator>> {
         unsafe {