Ignore:
Timestamp:
10/14/13 16:38:34 (11 years ago)
Author:
stoda
Message:

All tests working

TODO sometimes exceptiontest fails

File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/supervisor/src/main/java/omq/server/RemoteThreadPool.java

    r101 r102  
    44import java.util.ArrayList;
    55import java.util.List;
     6import java.util.ListIterator;
    67import java.util.concurrent.atomic.AtomicInteger;
    78
     
    102103                long now = System.currentTimeMillis();
    103104
    104                 int i = 0;
    105                 for (InvocationThread worker : workers) {
    106                         // Ensure there are at least minThreads available
    107                         if (workers.size() == minPoolThreads) {
    108                                 break;
    109                         }
     105                ListIterator<InvocationThread> lIter = workers.listIterator();
     106                while (workers.size() > minPoolThreads && lIter.hasNext()) {
     107                        InvocationThread worker = lIter.next();
    110108                        long lastExec = worker.getLastExecution();
    111109                        System.out.println("last - now = " + (now - lastExec) + " keep alive = " + keepAliveTime);
     
    114112                                try {
    115113                                        worker.kill();
    116                                         workers.remove(i);
     114                                        lIter.remove();
    117115                                } catch (IOException e) {
    118                                         // TODO Auto-generated catch block
    119                                         e.printStackTrace();
     116                                        logger.error(e);
    120117                                }
    121118
    122119                        }
    123                         i++;
    124120                }
    125121        }
Note: See TracChangeset for help on using the changeset viewer.