threading_issue.py

def askAdvice(self, state):
    global msgGive, msgAsk        
    msgGive[self.agentNumber] = []
    for i in range(numAgents):   
            msgAsk[i][self.agentNumber] = state

    while True:
        self.giveAdvice()
        if len(msgGive[self.agentNumber]) == numAgents - 1:
          break

    return (majorityVote(msgGive[self.agentNumber]))
      
def giveAdvice(self):
  for i in range(numAgents):
      if i == self.agentNumber or msgAsk[self.agentNumber][i] == 0:
          continue
          
      state = msgAsk[self.agentNumber][i]
      msgGive[i].append((self.agentNumber, -1))
      msgAsk[self.agentNumber][i] = 0

threads = []
agents = [Agent(1,j) for j in range(numAgents)]
for j in range(numAgents):
    t = threading.Thread(target=agents[j].run)
    threads.append(t)
t.start()