tange/parallel
1
0
Fork 0
mirror of https://git.savannah.gnu.org/git/parallel.git synced 2024-11-29 09:27:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

parallel: Update --bar/--progress/--eta more aggresively for: seq 1000 | parallel --eta -j0 sleep 0.{}

Browse source
This commit is contained in:
Ole Tange 2015-04-05 04:36:17 +02:00
parent 2e68cd95dc
commit 98c4da806f
1 changed files with 18 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
src/parallel
View file

@ -2258,19 +2258,28 @@ sub progress {
my ($columns,$last_column_time); my ($columns,$last_column_time);
sub terminal_columns { sub terminal_columns {
# Get the number of columns of the display # Get the number of columns of the terminal.
# Only update once per second.
# Returns: # Returns:
# number of columns of the screen # number of columns of the screen
if(not $columns or $last_column_time < time) { if(not $columns or $last_column_time < time) {
$last_column_time = time; $last_column_time = time;
$columns = $ENV{'COLUMNS'}; $columns = $ENV{'COLUMNS'};
if(not $columns) { if(not $columns) {
my $resize = qx{ sh -c 'resize 2>/dev/null' }; my $stty = qx{ stty -a </dev/tty };
$resize =~ /COLUMNS=(\d+);/ and do { $columns = $1; }; # FreeBSD/OpenBSD/NetBSD/Dragonfly/MirOS
# MacOSX/IRIX/AIX/Tru64
$stty =~ /(\d+) columns/ and do { $columns = $1; };
# GNU/Linux/Solaris
$stty =~ /columns (\d+)/ and do { $columns = $1; };
# Solaris-x86/HPUX/SCOsysV/UnixWare/OpenIndiana
$stty =~ /columns = (\d+)/ and do { $columns = $1; };
# QNX
$stty =~ /rows=\d+,(\d+)/ and do { $columns = $1; };
} }
if(not $columns) { if(not $columns) {
my $stty = qx{ stty -a </dev/tty }; my $resize = qx{ sh -c 'resize 2>/dev/null' };
$stty =~ /(\d+) columns/ and do { $columns = $1; } $resize =~ /COLUMNS=(\d+);/ and do { $columns = $1; };
} }
$columns ||= 80; $columns ||= 80;
} }
@ -2985,6 +2994,10 @@ sub reaper {
$Global::total_running--; $Global::total_running--;
delete $Global::running{$stiff}; delete $Global::running{$stiff};
start_more_jobs(); start_more_jobs();
if($opt::progress) {
my %progress = progress();
::status("\r",$progress{'status'});
}
} }
debug("run", "done "); debug("run", "done ");
return $children_reaped; return $children_reaped;