(Tasks.Task task)
| 66 | } |
| 67 | |
| 68 | void Run(Tasks.Task task) { |
| 69 | task.App = app; |
| 70 | String name = task.getClass().getName(); |
| 71 | int keyBound = task.getKeyBound(); |
| 72 | for (int i = 0, n = task.getKeyNumber(); i < n; i++) { |
| 73 | long key; |
| 74 | do |
| 75 | key = Random.getInstance().nextInt(keyBound); |
| 76 | while (!task.Keys.add(key)); |
| 77 | Tasks.getKeyCounter(name, key).increment(); |
| 78 | } |
| 79 | Tasks.getRunCounter(name).increment(); |
| 80 | Simulate.getInstance().RunningTasks.add(task.IsProcedure() |
| 81 | ? Task.runUnsafe(app.Zeze.newProcedure(task, name), DispatchMode.Normal) |
| 82 | : Task.runUnsafe(task::call, name, DispatchMode.Normal)); |
| 83 | } |
| 84 | |
| 85 | public static <K extends Comparable<K>> void clearDbTable(TableX<K, ?> table) throws Exception { |
| 86 | var t = System.nanoTime(); |
no test coverage detected