две нити параллельно только один становится выполнен в Java

-1

Я бегу два потока параллельно только один становится казнены:две нити параллельно только один становится выполнен в Java

countDown = new CountDownLatch(2); //tasks number 
    tasks = new ArrayList<Callable<Object>>();  
    //tasks.add(Executors.callable(new runCode(countDown, timelineTime2))); 
    tasks.add(Executors.callable(new runCode(countDown, timelineTime_sublist1,1))); 
    tasks.add(Executors.callable(new runCode(countDown, timelineTime_sublist2,2))); 
    executor.invokeAll(tasks);

В выходных данных, он начинается с:

Thread 1 running, 
Thread 2 running, 
Thread 1 running, 
Thread 2 running,

Но после этого продолжается только Thread 1.

Код для runCode является:

public static class runCode implements Runnable { 
    private final CountDownLatch countDown; 
    private final List<Long> timelineTimeI; 
    private final int v; 

    runCode (CountDownLatch countDown, List<Long> timelineTimeI, int v) { 
     this.countDown = countDown; 
     this.timelineTimeI = timelineTimeI; 
     this.v = v; 
     System.out.println("Thread "+v+ " running"); 
    } 

    public void run1 (List<Long> timelineTimeI) throws IOException, InterruptedException { 
     //do work 
     for (Long l : timelineTimeI) { 
      //if (v==2) thread.notifyAll(); 
      if (nb%1000==0) { 
       System.out.println("Thread "+v+ " running"); 
       System.out.println(nb + "/~ 80000"); 
       System.out.println("Number of active threads: "+ Thread.activeCount()); 
       //Print CPU Usage 
       //OperatingSystemMXBean opBean = ManagementFactory.getOperatingSystemMXBean(); 
       System.out.println("Total Usage: "+thread.getTotalUsage()); 
       System.out.println("CPU Usage by Server: "+(thread.getTotalUsage()-thread.getUsageByThread(Thread.currentThread()))+"%"); 
       System.out.println("CPU Usage by Client: "+thread.getUsageByThread(Thread.currentThread())+"%"); 
       totalUsage += thread.getTotalUsage(); 
       totalClientUsage += thread.getUsageByThread(Thread.currentThread()); 
       count++; 
       //System.out.println("CPU Usage: "+ opBean.getSystemLoadAverage()); 
      } 
      candidateSetSize = 0; 
      counter = t.get(l).size(); 
      //System.out.println("Counter: "+counter+" l: "+l+" t.get(l): "+t.get(l)); 

    for (Rating rate : t.get(l)) { 
     //System.out.println("Rate: "+rate+" "+rate.getRate()+" "+rate.getRid()+" "+rate.getUid()); 
     lastOnline.put(rate.getUid(), l);    
     //liked by user, so send like notification 
     if (rate.getRate() > averageRating.get(rate.getUid())) { 
        peers.get(rate.getUid()).sendLikeNotification(rate.getRid()); 
     } else { 
      //disliked by user, so send dislike notification 
        peers.get(rate.getUid()).sendDisLikeNotification(rate.getRid()); 
     } 
     //in the test data set so when a user sends a notification, it implies that user is online 
     if (l>tborne) {    
      candidateSetSize += peers.get(rate.getUid()).sendOnlineNotification(true);  
     } else { 
     candidateSetSize += peers.get(rate.getUid()).sendOnlineNotification(false); 
     } nb++; 
    } 
    // additional online status 
    for (Integer uid : userList) { 
     // if user has been online later than slot then send online 
     if (lastOnline.containsKey(uid)) { 
     if(l - lastOnline.get(uid) > SLOT) { 
      if (l>tborne) {    
      candidateSetSize += peers.get(uid).sendOnlineNotification(true);   
      } else { 
      candidateSetSize += peers.get(uid).sendOnlineNotification(false); 
      } 
      if(counterAddOnline.containsKey(uid)) { 
      counterAddOnline.put(uid, counterAddOnline.get(uid)+1); 
      } else { 
      counterAddOnline.put(uid, 1); 
      } 
      lastOnline.put(uid, l); 
      counter++; 
     } 
       } 
      } 
    candidateSetSizeOverTime.add(candidateSetSize/counter); 
     } 
    } 

    public void run() { 
    try { 
    run1(timelineTimeI); 
    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } catch (InterruptedException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
    } 
    countDown.countDown(); 
    System.out.println("Thread "+v+" finished"); 
    } 
}

источник

2013-10-03 user2843283

Пожалуйста, очистите весь код, который не имеет значения при задании такого вопроса. –

Я прочитал это, но я не понимаю, почему после начала параллели он использовал только Thread 1, а затем он закончился, когда выполнение потока 1 закончилось, и поток 2 не был выполнен. – user2843283

-1

Вы можете попытаться запустить другую тему в фоновом режиме, используя SwingWorker

http://docs.oracle.com/javase/tutorial/uiswing/concurrency/worker.html

источник

2013-10-03 15:40:25 Jeremy

Попробуем это, но я думаю, что поток начал правильно, но то только один поток был запущен, и программа закончилась после его выполнения, поэтому некоторые шаги потока 2 запускались при запуске, а остальные не выполнялись вообще – user2843283

'SwingWorker' предназначен для использования в контексте Swing, а не для общего многопоточности , –

if (nb%1000==0) :

если выше линия не соответствует действительности, которая является возможно, если список не имеет длину с кратным 1000 .... Указание ниже не будет выполнено

System.out.println("Thread "+v+ " running");

Это утверждение выполняется дважды для всех потоков, поскольку он выполняется в конструкторе и выполняется при нб = 0, которое, вероятно, начальное значение вашего нб

источник

2016-09-10 11:11:17 Positive

Move countDown.countDown() к началу run(). Затем оба потока начнутся прибл. в то же время. Первый поток ожидает до тех пор, пока не начнут отсчеты вторых потоков.

источник

2016-09-16 06:04:11

две нити параллельно только один становится выполнен в Java

ответ

Смежные вопросы