Intel® oneAPI Threading Building Blocks
Ask questions and share information about adding parallelism to your applications when using this threading library.

tbb::task priority and kill task

Ejaz_A_
Beginner
529 Views

Hi,

I am working on a socket application, my app is receiving very fast packets and i have to process and replay each packet within specific time (say 100 milliseconds). i am adding every packet to a queue, a thread is picking a packet and executing a tbb::task to process packet. i have 16 cores, and not able to process all packets in given time. 

my question is can i change task priority to high or kill task  which is not started in 50 ms and execute new task ?

what i am doing in my queue processing thread is:

while(1)

packet* p=q.pop();

process_packet* task = new(tbb::task::allocate_root()) process_packet(this,p);
tbb::task::spawn(*task);   
 
}
 
class process_packet: public tbb::task                                                                                                                                                                                  
{
public:                                                                                                                                                                                                          
process_packet(Parent *pPtr,Packet* pData)                                                                                                                                                                                          
: pParent(pPtr),
pPacket(pData)
{                                                                                                                                                                                                            
}                                                                                                                                                                                                            
tbb::task* execute()                                                                                                                                                                                           
{       
.....
 
processing...
.....
send reply..
 
 
return 0;                                                                                                                                                                                                  
}                                                                                                                                                                                                            
private:                                                                                                                                                                                                         
Parent* pParent;        
Packet* pData;
};

 

another question ,is it right approach to process socket packets, i don't know how much packets i will receive.
 
Thanks & Regards,
 
Ejaz
0 Kudos
2 Replies
Aleksei_F_Intel
Employee
529 Views

Hi Ejaz,

I do not see whether wait_for_all is called somewhere. TBB library does not guarantee processing of spawned tasks until that moment.

TBB library has priority support (please see the documentation) but we do not recommend using it because it involves higher overheads which are not always justified since in most of the time the semantics of the workload could be changed towards better use of the library features.

As an example, I would also recommend to try splitting the processing of each packet onto several tasks to extract more parallelism from the system. Consider use of TBB Flow Graph feature because it is a good match for such sporadic (not known in advance) semantics.

Regards,

Aleksei

0 Kudos
Ejaz_A_
Beginner
529 Views

Hi Fedotoy,

Thank for hints i will try TBB Flow Graph feature, i forgot to add wait_for_all in my post.

 

Thanks and Regard,

Ejaz

0 Kudos
Reply