Package com.leansoft.bigqueue

Examples of com.leansoft.bigqueue.IBigQueue.removeAll()

66
67
68
69
70
71
72
73
74
75
76
            sortedQueueMakers[i].join();
      } catch (InterruptedException e) {
        // ignore
      }
        }
        srcBigQueue.removeAll();
        srcBigQueue.close();
       
    MergeSortHelper.output("Merging and sorting the queues ...");
        MergeSorter[] mergeSorters = new MergeSorter[threadNum];
        for(int i = 0; i < threadNum; i++) {
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
      previousItem = item;
    }
    MergeSortHelper.output("Validation finished.");
   
    // have done with target sorted queue, empty it and delete back data files to save disk space
    targetSortedQueue.removeAll();
    targetSortedQueue.close();
  }
 
  private static final AtomicInteger populatedItemCount = new AtomicInteger(0);
 
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
    long start = System.currentTimeMillis();
    MergeSortHelper.output("Making queue of sorted queues ...");
    Queue<IBigQueue> queueOfSortedQueues = new LinkedList<IBigQueue>();
    MergeSortHelper.makeQueueOfSortedQueues(srcBigQueue, maxInMemSortNumOfItems, queueOfSortedQueues);
    // have done with source queue, empty it and delete back data files to save disk space
    srcBigQueue.removeAll();
    srcBigQueue.close();
   
    MergeSortHelper.output("Merging and sorting the queues ...");
    MergeSortHelper.mergeSort(queueOfSortedQueues, maxMergeSortWays);
    long end = System.currentTimeMillis();
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
      previousItem = item;
    }
    MergeSortHelper.output("Validation finished.");
   
    // have done with target sorted queue, empty it and delete back data files to save disk space
    targetSortedQueue.removeAll();
    targetSortedQueue.close();
   
    bigArray.close();
  }
 
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.