[phyrrus9]

So, I wrote a tutorial thread today about creating command line program progress bars, for another member on discord. During that conversation we talked about queueing them and making it so you could do simultaneous downloads and display those on screen, then implementing a basic (mutex style) queue. This is a little bit less of a tutorial and more of just a posting, but I went ahead and wrote a demo for it. Here's the code:

Code:

/* simple example of using ncurses to display a queue of progress bars * save this file as ncprogress.c * compile with gcc -o ncp ncprogress.c -pthread -lncurses * change MAX_BARS to the size you want your queue to be * run ./ncp to test it out */ #include <stdlib.h> #include <stdio.h> #include <unistd.h> #include <time.h> #include <pthread.h> #include <ncurses.h> #define MAX_BARS 5 WINDOW *positions[MAX_BARS] = { NULL }; struct progressContext { void (*callback)(unsigned, unsigned, struct progressContext *); WINDOW *win; char *name; }; struct threadContext { struct progressContext *progress; int position; unsigned seconds; pthread_t threadId; }; void waitLoop(unsigned ms, unsigned interval, struct progressContext *context) { unsigned i, j, s, count = ms/interval; for (i = 0, s = 0; i < ms; i += interval, ++s) { (*context->callback)(s % 4, (i * 100) / ms, context); usleep(interval * 1000); } (*context->callback)(0, 100, context); printf("\n"); } void progressw(unsigned spin, unsigned step, struct progressContext *ctx) { int i; const char *pgstep = "|\\-/"; wclear(ctx->win); wprintw(ctx->win, "Your title here, this thread is %s seconds\n[", ctx->name); // print window title first for (i = 0; i < step; ++i) wprintw(ctx->win, "#"); // print bar for (; i < 100; ++i) wprintw(ctx->win, " "); // print blank space wprintw(ctx->win, "] %c ", step > 99 ? ' ' : pgstep[spin]); wrefresh(ctx->win); } void *threadWrapper(void *arg) { } int selectPosition() { int i; for (i = 0; i < MAX_BARS; ++i) if (positions[i] == NULL) return i; return -1; } void *threadEntry(void *arg) { struct threadContext *ctx; struct progressContext *pctx; ctx = arg; pctx = ctx->progress; waitLoop(ctx->seconds * 1000, 1000, pctx); werase(pctx->win); wrefresh(pctx->win); delwin(pctx->win); free(pctx->name); free(pctx); usleep(200 * 1000); positions[ctx->position] = NULL; // put the window back in the list free(ctx); return NULL; } void runThread(unsigned seconds, void (*callback)(unsigned, unsigned, struct progressContext *)) { int position; struct threadContext *ctx; do { position = selectPosition(); } while (position < 0); // wait until we get a window positions[position] = (void *)1; // reserve our spot before we create the window, we will change this later positions[position] = newwin(2, 120, position * 2, 0); // create an ncurses window for it wclear(positions[position]); wrefresh(positions[position]); // initialize the window ctx = malloc(sizeof(struct threadContext)); ctx->threadId = 0; ctx->position = position; ctx->seconds = seconds; ctx->progress = malloc(sizeof(struct progressContext)); ctx->progress->callback = callback; ctx->progress->win = positions[position]; ctx->progress->name = malloc(8); sprintf(ctx->progress->name, "%d", seconds); ctx->threadId = pthread_create(&ctx->threadId, NULL, threadEntry, ctx); } int running() { int i; for (i = 0; i < MAX_BARS; ++i) if (positions[i] != NULL) return 1; return 0; } int main() { int i; const int ndownloads = 18; initscr(); refresh(); noecho(); srand(time(NULL)); for (i = 0; i < ndownloads; ++i) { runThread(rand() % 10 + 5, &progressw); // run for random time between 5 and 10 seconds usleep(750 * 1000); //a time out } sleep(1); // wait for a thread to start while (running()); // loop while we wait refresh(); endwin(); return 0; }

And, for those of you who want the syntax highlighting, click here
Or for the raw code download, click here