Configuration conf = new Configuration();

    Job job = new Job(conf, "SolerRandomHit");

    job.setOutputKeyClass(Text.class);

    job.setOutputValueClass(IntWritable.class);

    job.setMapperClass(MultithreadedMapper.class);

您需要使用multi-threadedmaprunner—只需在jobconf的setmaprunnerclass方法中设置它，并且不要忘记将mapred.map.multi-threadedrunner.threads设置为所需的并发级别。
还有一种方法，你应该：
将multithreadedmapper设置为作业类型对象中的Map器类
呼叫 MultithreadedMapper.setMapperClass 和你实际的Map绘制类
呼叫 MultithreadedMapper.setNumberOfThreads 具有理想的并发级别
但是要小心，你的Map器类应该是线程安全的，它的设置和清理方法会被多次调用，所以把多线程apper和多输出混合在一起不是一个聪明的主意，除非你实现了你自己的多线程apper类。

出于隔离的目的，hadoop故意不在一个jvm中同时运行多个任务。在独立（本地）模式下，只使用一个jvm。如果您想利用您的四个核心，您应该在伪分布式模式下运行，并将最大并发任务数增加到四个。你可以用 mapred.tasktracker.map.tasks.maximum 以及 mapred.tasktracker.reduce.tasks.maximum 属性。