How to automatic loop run again when finish ?

[DarKWinGTM]

import re
import os
import pip
import sys
import time
import random
import _thread
import asyncio
import datetime
import threading


try:
	__import__('proxybroker')
	__import__('requests')
except:
	print("Trying to Install required module: requireds\n")
	os.system('python -m pip install requireds')
	print("Trying to Install required module: proxybroker\n")
	os.system('python -m pip install --upgrade proxybroker')
finally:
	import requests
	from proxybroker import Broker


async def post(proxies, need):
	while True:

		proxy	=	await proxies.get() 

		try:
			query		+=	1
		except:
			query		=+	1
		if proxy is None:
			break
		elif proxy.avg_resp_time <= 1.50:
			port('https' if 'HTTPS' in proxy.types else 'http', proxy.host, proxy.port, 'type', proxy.types, query, need)
		else:
			print('%s - %s://%s:%d - %s:%s' % ('--', 'https' if 'HTTPS' in proxy.types else 'http', proxy.host, proxy.port, query, main.flow(-1)))

class port():
	def __init__(self, protocol, host, port, mode, types, query, need):
		self.protocol	=	protocol
		self.host		=	host
		self.port		=	port
		self.mode		=	mode
		self.types		=	types
		self.query		=	query
		self.need		=	need
		self.proxyes	=	{
			"http"	: '{0}://{1}:{2}'.format('socks5' if 'SOCKS5' in list(self.types)[0] else 'http', self.host, self.port), 
			"https" : '{0}://{1}:{2}'.format('socks5' if 'SOCKS5' in list(self.types)[0] else 'https', self.host, self.port), 
			"ftp"	: '{0}://{1}:{2}'.format('socks5' if 'SOCKS5' in list(self.types)[0] else 'ftp', self.host, self.port)
		}
		if self.mode == 'type':
			self.thread	= _thread.start_new_thread(self.type, ())
		else:
			return
	def type(self):
	
		#	time.sleep(random.choice([2.5, 5.0, 7.5, 10.0, 12.5]))
		
		try:
			open('D:\\proxies.hig', 'x+')
		except FileExistsError:
			open('D:\\proxies.hig', 'r+')
		try:
			open('D:\\proxies.ihi', 'x+')
		except FileExistsError:
			open('D:\\proxies.ihi', 'r+')
		try:
			open('D:\\proxies.pci', 'x+')
		except FileExistsError:
			open('D:\\proxies.pci', 'r+')
		try:
			open('D:\\proxies.low', 'x+')
		except FileExistsError:
			open('D:\\proxies.low', 'r+')
			
		try:
			self.jadata	=	requests.get('https://v2.api.iphub.info/guest/ip/{0}?c=Fae9gi8a'.format(self.host), proxies=self.proxyes).json()
		except:
			self.jadata	=	{}
			pass
		try:
			self.jbdata =	requests.get('https://proxycheck.io/v2/{0}'.format(self.host), proxies=self.proxyes).json()
		except:
			self.jbdata	=	{}
			pass
			
		try:
			if (not self.jadata['block'] == 1 and self.jbdata[self.host]['proxy'] == 'no') and not re.search(self.host, open('D:\\proxies.hig', 'r').read()):
				with open('D:\\proxies.hig', 'a+') as self.h:
					self.h.write(
						(
							'%s_%s_%s://%s:%d\n' % (
								datetime.datetime.fromtimestamp(time.time()).strftime('%Y-%m-%d %H:%M:%S').replace(' ', '_'), 
								self.types, 
								self.protocol, 
								self.host, 
								self.port
							)
						).replace(' ', '')
					)
			elif not self.jadata['block'] == 1 and not re.search(self.host, open('D:\\proxies.ihi', 'r').read()):
				with open('D:\\proxies.ihi', 'a+') as self.m:
					self.m.write(
						(
							'%s_%s_%s://%s:%d\n' % (
								datetime.datetime.fromtimestamp(time.time()).strftime('%Y-%m-%d %H:%M:%S').replace(' ', '_'), 
								self.types, 
								self.protocol, 
								self.host, 
								self.port
							)
						).replace(' ', '')
					)
			elif self.jbdata[self.host]['proxy'] == 'no' and not re.search(self.host, open('D:\\proxies.pci', 'r').read()):
				with open('D:\\proxies.pci', 'a+') as self.m:
					self.m.write(
						(
							'%s_%s_%s://%s:%d\n' % (
								datetime.datetime.fromtimestamp(time.time()).strftime('%Y-%m-%d %H:%M:%S').replace(' ', '_'), 
								self.types, 
								self.protocol, 
								self.host, 
								self.port
							)
						).replace(' ', '')
					)
			elif not self.jadata == {} or not self.jbdata == {}:
				with open('D:\\proxies.low', 'a+') as self.l:
					self.l.write(
						(
							'%s_%s_%s://%s:%d\n' % (
								datetime.datetime.fromtimestamp(time.time()).strftime('%Y-%m-%d %H:%M:%S').replace(' ', '_'), 
								self.types, 
								self.protocol, 
								self.host, 
								self.port
							)
						).replace(' ', '')
					)
			print('%d%s - %s://%s:%d - %s:%s' % (self.jadata['block'], '0' if self.jbdata[self.host]['proxy'] == 'no' else '1', self.protocol, self.host, self.port, self.query, main.flow(-1)))
		except:
			print('%d - %s://%s:%d - %s:%s' % (-1, self.protocol, self.host, self.port, self.query, main.flow(-1)))
		finally:
			return

class main():
	def __init__(self, need, time):
		self.need	=	need
		self.time	=	time
		self.loop	=	asyncio.get_event_loop()
		self.queu	=	asyncio.Queue()
		self.brok	=	Broker(
			self.queu, 
			timeout		=	5, 
			max_conn	=	need, 
			max_tries	=	2
		)
		self.task	=	asyncio.gather(
			self.brok.find(
				types	=	[
					'SOCKS5', 
					'SOCKS4', 
					'HTTPS'
				], 
				limit	=	self.need
			),
			post(self.queu, self.need), 
		)
		self.thread	=	_thread.start_new_thread(
			self.gone, ()
		)
		main.flow(self.need)
		main.repo()
	def gone(self):
		try:
			self.loop.run_until_complete(self.task)
		except:
			pass
		finally:
			while roll >= 1: time.sleep(self.time)
			self.loop	=	None
			self.queu	=	None
			self.brok	=	None
			self.task	=	None
			main(self.need, self.time)
	def flow(g):
		global roll
		try:
			if g >= 1:
				roll = g
			else:
				roll += g
		except:
			pass
		finally:
			return roll
	def repo():
		print(time.ctime())


if __name__ == '__main__':
	main(20, 10)

[DarKWinGTM]

Unhandled exception in thread started by <bound method main.gone of <main.main object at 0x0000025DDD89B588>> Traceback (most recent call last): File "C:\Users\User\Desktop\PB.py", line 191, in gone main(self.need, self.time) File "C:\Users\User\Desktop\PB.py", line 156, in init self.loop = asyncio.get_event_loop() File "C:\Python\Python37\lib\asyncio\events.py", line 644, in get_event_loop % threading.current_thread().name) RuntimeError: There is no current event loop in thread 'Dummy-1'.