Skip to content

Commit

Permalink
Execute tasks on the provided TaskSchduler
Browse files Browse the repository at this point in the history
Fixes #40.
  • Loading branch information
michaelklishin committed Mar 12, 2015
1 parent 113a5fe commit c654465
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ public ConsumerWorkService() :

public ConsumerWorkService(TaskScheduler scheduler)
{
this.scheduler = scheduler;
this.workPool = new BatchingWorkPool<IModel, Action>();
}

Expand Down Expand Up @@ -47,7 +48,7 @@ public void ExecuteThunk()
if (this.workPool.FinishWorkBlock(key))
{
var t = new Task(new Action(ExecuteThunk));
t.Start();
t.Start(this.scheduler);
}
}
}
Expand Down

0 comments on commit c654465

Please sign in to comment.