| 595 | } |
| 596 | |
| 597 | void init() |
| 598 | { |
| 599 | processActive = false; |
| 600 | serialized.clear(); |
| 601 | if (transform) { |
| 602 | QDataStream out(&serialized, QFile::WriteOnly); |
| 603 | transform->serialize(out); |
| 604 | tcount = Globals->parallelism; |
| 605 | counter.acquire(counter.available()); |
| 606 | counter.release(this->concurrentCount); |
| 607 | } |
| 608 | } |
| 609 | |
| 610 | static QSemaphore counter; |
| 611 | mutable int tcount; |