片方のスレッドはキューにたまったSQL文を発行する
もう片方のスレッドはCSVを1行ずつ読み、splitしてSQL文をキューにためる

これじゃ駄目なの?