MCPcopy Create free account
hub / github.com/questdb/questdb / startThread

Method startThread

core/src/main/java/io/questdb/log/LogFactory.java:410–418  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

408 }
409
410 public void startThread() {
411 assert !closed.get();
412 if (running.compareAndSet(false, true)) {
413 for (int i = 0, n = jobs.size(); i < n; i++) {
414 loggingWorkerPool.assign(jobs.get(i));
415 }
416 loggingWorkerPool.start();
417 }
418 }
419
420 /**
421 * Converts fully qualified class name into an abbreviated form:

Callers 4

testFlushJobsAndCloseMethod · 0.95
flushJobsMethod · 0.95
initMethod · 0.95
setUpMethod · 0.45

Calls 4

getMethod · 0.65
sizeMethod · 0.65
assignMethod · 0.45
startMethod · 0.45

Tested by 1

testFlushJobsAndCloseMethod · 0.76