Lines Matching refs:nthreads
255 taskq_create(const char *name, int nthreads, pri_t pri, in taskq_create() argument
264 ASSERT3S(nthreads, >=, 0); in taskq_create()
265 ASSERT3S(nthreads, <=, 100); in taskq_create()
266 pct = MIN(nthreads, 100); in taskq_create()
269 nthreads = (sysconf(_SC_NPROCESSORS_ONLN) * pct) / 100; in taskq_create()
270 nthreads = MAX(nthreads, 1); /* need at least 1 thread */ in taskq_create()
272 ASSERT3S(nthreads, >=, 1); in taskq_create()
282 tq->tq_active = nthreads; in taskq_create()
283 tq->tq_nthreads = nthreads; in taskq_create()
288 tq->tq_threadlist = kmem_alloc(nthreads * sizeof (kthread_t *), in taskq_create()
298 for (t = 0; t < nthreads; t++) in taskq_create()
308 int nthreads = tq->tq_nthreads; in taskq_destroy() local
330 kmem_free(tq->tq_threadlist, nthreads * sizeof (kthread_t *)); in taskq_destroy()
348 taskq_create_synced(const char *name, int nthreads, pri_t pri, in taskq_create_synced() argument
352 kthread_t **kthreads = kmem_zalloc(sizeof (*kthreads) * nthreads, in taskq_create_synced()
359 tq = taskq_create(name, nthreads, minclsyspri, nthreads, INT_MAX, in taskq_create_synced()
362 VERIFY(tq->tq_nthreads == nthreads); in taskq_create_synced()
364 for (int i = 0; i < nthreads; i++) { in taskq_create_synced()