@@ -44,7 +44,7 @@ pub fn deinit(self: *Self) void {
44
44
std .debug .assert (self .num_tasks == 0 );
45
45
}
46
46
47
- pub fn createTask (self : * Self , priority : Priority , func : anytype , ctx : anytype ) ! * Queue.Node {
47
+ pub fn createTask (self : * Self , priority : Priority , func : anytype , ctx : anytype ) ! Task {
48
48
self .queue_mutex .lock ();
49
49
defer self .queue_mutex .unlock ();
50
50
@@ -71,7 +71,7 @@ pub fn createTask(self: *Self, priority: Priority, func: anytype, ctx: anytype)
71
71
return task ;
72
72
}
73
73
74
- pub fn destroyTask (self : * Self , task : * Queue.Node ) void {
74
+ pub fn destroyTask (self : * Self , task : Task ) void {
75
75
self .queue_mutex .lock ();
76
76
if (task .data .scheduled ) {
77
77
self .queue .remove (task );
@@ -86,7 +86,7 @@ pub fn destroyTask(self: *Self, task: *Queue.Node) void {
86
86
self .num_tasks -= 1 ;
87
87
}
88
88
89
- pub fn scheduleTask (self : * Self , task : * Queue.Node ) void {
89
+ pub fn scheduleTask (self : * Self , task : Task ) void {
90
90
self .queue_mutex .lock ();
91
91
defer self .queue_mutex .unlock ();
92
92
@@ -98,7 +98,7 @@ pub fn scheduleTask(self: *Self, task: *Queue.Node) void {
98
98
self .addToQueue (task );
99
99
}
100
100
101
- pub fn addToQueue (self : * Self , task : * Queue.Node ) void {
101
+ fn addToQueue (self : * Self , task : * Queue.Node ) void {
102
102
task .data .scheduled = true ;
103
103
self .queue .prepend (task );
104
104
self .queue_not_empty .signal ();
0 commit comments