human
Give me a the Python code you requested given the following:
Complete the below
def _run_server(local_addr, local_addr_family, local_socket_type, local_linger_args, remote_addr, remote_addr_family, remote_socket_type, queue):

    ''''Run the server.
executed in the subprocess
    :param local_addr: listening address
    :param local_addr_family: listening address family.
one of socket.AF_*
    :param local_socket_type: listening socket type.
typically
    socket.SOCK_STREAM
    :param tuple local_linger_args: SO_LINGER sockoverride for the local
    connection sockets, to be configured after connection is accepted.
    Pass None to not change SO_LINGER. Otherwise, its a two-tuple, where the
    first element is the `l_onoff` switch, and the second element is the
    `l_linger` value in seconds
    :param remote_addr: address of the target server. Pass None to have
    ForwardServer behave as echo server
    :param remote_addr_family: address family for connecting to target server;
    one of socket.AF_*
    :param remote_socket_type: socket type for connecting to target server;
    typically socket.SOCK_STREAM
    :param multiprocessing.Queue queue: queue for depositing the forwarding
    server\'s actual listening socket address family and bound address. The
    parent process waits for this.'
    '''
assistant
#Here is the Python code you requested.
    class _ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer, object, ):
        'Threaded    streaming    server    for    forwarding'
        address_family = local_addr_family
        socket_type = local_socket_type
        allow_reuse_address = True
        def __init__(self):
            handler_class_factory = partial(_TCPHandler, local_linger_args=local_linger_args, remote_addr=remote_addr, remote_addr_family=remote_addr_family, remote_socket_type=remote_socket_type)
            super(_ThreadedTCPServer, self).__init__(local_addr, handler_class_factory, bind_and_activate=True)
    server = _ThreadedTCPServer()
    queue.put([server.socket.family, server.server_address])
    queue.close()
    server.serve_forever()