diff --git a/src/ckpool.h b/src/ckpool.h
index d840528e..a36be659 100644
--- a/src/ckpool.h
+++ b/src/ckpool.h
@@ -210,6 +210,8 @@ struct ckpool_instance {
 
 	/* Private data for each process */
 	void *data;
+	/* Private generic workqueues if this process has them */
+	ckwq_t *ckwqs;
 };
 
 #ifdef USE_CKDB
diff --git a/src/stratifier.c b/src/stratifier.c
index 501aabd4..324ddc2a 100644
--- a/src/stratifier.c
+++ b/src/stratifier.c
@@ -5007,7 +5007,7 @@ int stratifier(proc_instance_t *pi)
 	sdata->ssends = create_ckmsgq(ckp, "ssender", &ssend_process);
 	/* Create as many generic workqueue threads as there are CPUs */
 	threads = sysconf(_SC_NPROCESSORS_ONLN);
-	sdata->ckwqs = create_ckwqs(ckp, "strat", threads);
+	ckp->ckwqs = sdata->ckwqs = create_ckwqs(ckp, "strat", threads);
 	sdata->sauthq = create_ckmsgq(ckp, "authoriser", &sauth_process);
 	if (!CKP_STANDALONE(ckp)) {
 		sdata->ckdbq = create_ckmsgq(ckp, "ckdbqueue", &ckdbq_process);