为什么这样写java线程不能用?

public class test {

    @Test
    public void kafkaProgram(){
        String topic = "visited";
        KafkaP producer  = new KafkaP(topic);
        KafkaC consumer = new KafkaC(topic);
        Thread t1 = new Thread(producer);
        t1.start();
        Thread t2 = new Thread(consumer);
        t2.start();
        Thread t3 = new Thread(consumer);
        t3.start();
    }

}

class KafkaP extends Thread{
    @Override
    public void run(){
        while (true){
            System.out.println("开始生产数据");
        }
    }
}

class KafkaC extends Thread{
    @Override
    public void run(){
        System.out.println("开始消费数据");
        while (true){
            synchronized (KafkaC.class){
                    System.out.println("消费数据:"+record.value());
            }
        }
    }
}

代码只包含了和线程相关的
省略部分的代码单独调试下都没有问题

如果用start方法 则三个线程都只会运行一遍 没有达到一直跑的效果
如果用run方法 则只会阻塞在t1, t2t3不会运行

是不是线程这里写错了?

阅读 1.2k
1 个回答

放main 方法里面跑。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题