def create_threads(self):
<EOL>neutron_thrd = utils.EventProcessingThread('<STR_LIT>',<EOL>self.neutron_event,<EOL>'<STR_LIT>',<EOL>self._excpq)<EOL>self.dfa_threads.append(neutron_thrd)<EOL>qp_thrd = utils.EventProcessingThread('<STR_LIT>', self,<EOL>'<STR_LIT>', self._excpq)<EOL>self.dfa_threads.append(qp_thrd)<EOL>keys_thrd = utils.EventProcessingThread('<STR_LIT>',<EOL>self.keystone_event,<EOL>'<STR_LIT>', self._excpq)<EOL>self.dfa_threads.append(keys_thrd)<EOL>hb_thrd = utils.EventProcessingThread('<STR_LIT>', self, '<STR_LIT>',<EOL>self._excpq)<EOL>self.dfa_threads.append(hb_thrd)<EOL>if self.dcnm_event is not None:<EOL><INDENT>dcnmL_thrd = utils.EventProcessingThread('<STR_LIT>',<EOL>self.dcnm_event,<EOL>'<STR_LIT>',<EOL>self._excpq)<EOL>self.dfa_threads.append(dcnmL_thrd)<EOL><DEDENT>fr_thrd = utils.PeriodicTask(interval=constants.FAIL_REC_INTERVAL,<EOL>func=self.add_events,<EOL>event_queue=self.pqueue,<EOL>priority=self.PRI_LOW_START + <NUM_LIT:10>,<EOL>excq=self._excpq)<EOL>for t in self.dfa_threads:<EOL><INDENT>t.start()<EOL><DEDENT>fr_thrd.run()<EOL>
Create threads on server.