прекратить выполнение

Формирую задачу, которая будет выполняться в нескольких потоках с помощью stl следующим образом:

Мне нужно чтобы задача в очереди зависимости от Exception могла либо выполнятся далее, либо прерываться, и помещаться в таблицу failed_jobsСейчас пытаюсь сделать так: