bitthebyte / needle Goto Github PK

from threading import Thread
from queue import Queue

q = Queue()

options = {
          'threads':20,
          'targets':['http://php.net','http://hackerone.com']
           }

def threader():
    while True:
           item = q.get()
           main_func(item)
           q.task_done()
def main_func(options):
    print(options['targets'])

for _ in range(options['threads']):
    p = Thread(target=threader)
    p.daemon = True
    p.start()
for opts in options['targets']:
   q.put(opts)
q.join()

['http://php.net', 'http://hackerone.com']
['http://php.net', 'http://hackerone.com']

import needle

options = {
          'threads':20,
          'targets':['http://php.net','http://hackerone.com']
           }
def main_func(options):
    print(options['targets'])

for i in needle.GroupWorkers(target=main_func, arguments=options, concurrent=options['threads']):
    print(i.arguments, i._return )

[ERROR]: main_func() takes 1 positional argument but 7 were given
[ERROR]: main_func() takes 1 positional argument but 7 were given
('t', 'a', 'r', 'g', 'e', 't', 's') RUNTIME_ERROR
('t', 'h', 'r', 'e', 'a', 'd', 's') RUNTIME_ERROR