Threading

Figure 15: Thread.

To simplify the construction of the sub threads, DPThreadPipeC<> integrates all the threading and buffers into one class. All the user needs to do is to supply the processing operation that should be performed and the size of the buffers to use. The DPThreadPipeC<> is shown in Figure 15. It allows the previous multiplex example to be simplified to the following.

DPIFileC<RealT>("in.dat") »= DPMultiplex(DPThreadPipeC<RealT>(DPOffsetScale(4.0,2.0),2),3) »= DPOFileC<RealT>("out.dat");

The structure this creates is identical to that shown in Figure 14.

Normal classes:

DPThreadPipeC

MT safe queue handle.

Normal functions:

DPThread(const DPProcessC &,IntT)

Develop classes:

DPThreadPipeBodyC

MT safe queue body